Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / ndp / fx / src / Net / System / Net / Mail / DelegatedStream.cs / 1 / DelegatedStream.cs
//------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Net { using System; using System.Net.Sockets; using System.IO; internal class DelegatedStream : Stream { Stream stream; NetworkStream netStream; protected DelegatedStream() { } protected DelegatedStream(Stream stream) { if (stream == null) throw new ArgumentNullException("stream"); this.stream = stream; netStream = stream as NetworkStream; } protected Stream BaseStream { get { return this.stream; } } public override bool CanRead { get { return this.stream.CanRead; } } public override bool CanSeek { get { return this.stream.CanSeek; } } public override bool CanWrite { get { return this.stream.CanWrite; } } public override long Length { get { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); return this.stream.Length; } } public override long Position { get { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); return this.stream.Position; } set { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); this.stream.Position = value; } } public override IAsyncResult BeginRead(byte[] buffer, int offset, int count, AsyncCallback callback, object state) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); IAsyncResult result = null; if(netStream != null){ result = this.netStream.UnsafeBeginRead (buffer, offset, count, callback, state); } else{ result = this.stream.BeginRead (buffer, offset, count, callback, state); } return result; } public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, object state) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); IAsyncResult result = null; if(netStream != null){ result = this.netStream.UnsafeBeginWrite(buffer, offset, count, callback, state); } else{ result = this.stream.BeginWrite (buffer, offset, count, callback, state); } return result; } //This calls close on the inner stream //however, the stream may not be actually closed, but simpy flushed public override void Close() { this.stream.Close(); } public override int EndRead(IAsyncResult asyncResult) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); int read = this.stream.EndRead (asyncResult); return read; } public override void EndWrite(IAsyncResult asyncResult) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); this.stream.EndWrite (asyncResult); } public override void Flush() { this.stream.Flush(); } public override int Read(byte[] buffer, int offset, int count) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); int read = this.stream.Read(buffer, offset, count); return read; } public override long Seek(long offset, SeekOrigin origin) { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); long position = this.stream.Seek(offset, origin); return position; } public override void SetLength(long value) { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); this.stream.SetLength(value); } public override void Write(byte[] buffer, int offset, int count) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); this.stream.Write(buffer, offset, count); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// Copyright (c) Microsoft Corporation. All rights reserved. // //----------------------------------------------------------------------------- namespace System.Net { using System; using System.Net.Sockets; using System.IO; internal class DelegatedStream : Stream { Stream stream; NetworkStream netStream; protected DelegatedStream() { } protected DelegatedStream(Stream stream) { if (stream == null) throw new ArgumentNullException("stream"); this.stream = stream; netStream = stream as NetworkStream; } protected Stream BaseStream { get { return this.stream; } } public override bool CanRead { get { return this.stream.CanRead; } } public override bool CanSeek { get { return this.stream.CanSeek; } } public override bool CanWrite { get { return this.stream.CanWrite; } } public override long Length { get { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); return this.stream.Length; } } public override long Position { get { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); return this.stream.Position; } set { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); this.stream.Position = value; } } public override IAsyncResult BeginRead(byte[] buffer, int offset, int count, AsyncCallback callback, object state) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); IAsyncResult result = null; if(netStream != null){ result = this.netStream.UnsafeBeginRead (buffer, offset, count, callback, state); } else{ result = this.stream.BeginRead (buffer, offset, count, callback, state); } return result; } public override IAsyncResult BeginWrite(byte[] buffer, int offset, int count, AsyncCallback callback, object state) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); IAsyncResult result = null; if(netStream != null){ result = this.netStream.UnsafeBeginWrite(buffer, offset, count, callback, state); } else{ result = this.stream.BeginWrite (buffer, offset, count, callback, state); } return result; } //This calls close on the inner stream //however, the stream may not be actually closed, but simpy flushed public override void Close() { this.stream.Close(); } public override int EndRead(IAsyncResult asyncResult) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); int read = this.stream.EndRead (asyncResult); return read; } public override void EndWrite(IAsyncResult asyncResult) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); this.stream.EndWrite (asyncResult); } public override void Flush() { this.stream.Flush(); } public override int Read(byte[] buffer, int offset, int count) { if (!CanRead) throw new NotSupportedException(SR.GetString(SR.ReadNotSupported)); int read = this.stream.Read(buffer, offset, count); return read; } public override long Seek(long offset, SeekOrigin origin) { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); long position = this.stream.Seek(offset, origin); return position; } public override void SetLength(long value) { if (!CanSeek) throw new NotSupportedException(SR.GetString(SR.SeekNotSupported)); this.stream.SetLength(value); } public override void Write(byte[] buffer, int offset, int count) { if (!CanWrite) throw new NotSupportedException(SR.GetString(SR.WriteNotSupported)); this.stream.Write(buffer, offset, count); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007.
Link Menu

This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- EnumMemberAttribute.cs
- ControllableStoryboardAction.cs
- XmlSequenceWriter.cs
- ProcessThreadCollection.cs
- EventProxy.cs
- ValidatorCollection.cs
- PartialArray.cs
- ObjectCacheHost.cs
- SynchronizationLockException.cs
- PathGradientBrush.cs
- OleTxTransaction.cs
- WindowsFormsSynchronizationContext.cs
- ColorTransform.cs
- BitmapEffect.cs
- CustomErrorsSectionWrapper.cs
- HttpConfigurationContext.cs
- TextElementCollectionHelper.cs
- TextServicesContext.cs
- TypeGeneratedEventArgs.cs
- MembershipSection.cs
- NavigationEventArgs.cs
- SecurityRuntime.cs
- XmlWriterSettings.cs
- ImageSourceValueSerializer.cs
- X509IssuerSerialKeyIdentifierClause.cs
- DBCSCodePageEncoding.cs
- Expressions.cs
- Avt.cs
- UIPermission.cs
- ExtensionsSection.cs
- AutoGeneratedField.cs
- Simplifier.cs
- ProxyFragment.cs
- ActivityBindForm.cs
- TransactionValidationBehavior.cs
- XmlSchemaImporter.cs
- VideoDrawing.cs
- QilInvokeEarlyBound.cs
- RotateTransform3D.cs
- TextUtf8RawTextWriter.cs
- DataGridViewSelectedColumnCollection.cs
- TransformedBitmap.cs
- SafeViewOfFileHandle.cs
- Transform3DCollection.cs
- ServiceCredentialsElement.cs
- ComplexType.cs
- DPCustomTypeDescriptor.cs
- HitTestParameters3D.cs
- OrderablePartitioner.cs
- XmlSerializerFormatAttribute.cs
- ProfileBuildProvider.cs
- ListSortDescription.cs
- PixelShader.cs
- InvalidateEvent.cs
- VideoDrawing.cs
- XmlHierarchicalDataSourceView.cs
- SoapFault.cs
- StringAnimationUsingKeyFrames.cs
- BamlBinaryReader.cs
- PartialList.cs
- PropertyInfo.cs
- Token.cs
- BinaryCommonClasses.cs
- lengthconverter.cs
- HtmlTableCell.cs
- NetworkInformationException.cs
- CodeGotoStatement.cs
- ViewPort3D.cs
- EdmError.cs
- XmlUrlEditor.cs
- DashStyle.cs
- StringExpressionSet.cs
- HttpGetProtocolImporter.cs
- TextRenderer.cs
- RegisteredScript.cs
- CommonGetThemePartSize.cs
- XmlObjectSerializerWriteContext.cs
- TraceInternal.cs
- SqlUnionizer.cs
- FilterException.cs
- StaticSiteMapProvider.cs
- StateWorkerRequest.cs
- Int16Storage.cs
- LogicalExpr.cs
- CompilerError.cs
- CriticalHandle.cs
- ListItemConverter.cs
- ConfigXmlComment.cs
- RSACryptoServiceProvider.cs
- PageParserFilter.cs
- FixedDSBuilder.cs
- BufferedGraphicsContext.cs
- COM2ExtendedBrowsingHandler.cs
- XmlSerializationGeneratedCode.cs
- ControlParameter.cs
- UInt32Storage.cs
- PageThemeCodeDomTreeGenerator.cs
- DesignerUtility.cs
- ConnectionPointConverter.cs
- DataGrid.cs