Code:
/ 4.0 / 4.0 / DEVDIV_TFS / Dev10 / Releases / RTMRel / ndp / fx / src / Net / System / Net / Mail / DelegatedStream.cs / 1305376 / 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
- SqlTopReducer.cs
- _ListenerResponseStream.cs
- TableMethodGenerator.cs
- RoleServiceManager.cs
- MediaContextNotificationWindow.cs
- IPEndPoint.cs
- Thumb.cs
- Int16AnimationBase.cs
- CursorInteropHelper.cs
- BridgeDataReader.cs
- Config.cs
- ShaderEffect.cs
- CriticalFinalizerObject.cs
- CharEntityEncoderFallback.cs
- OracleParameter.cs
- shaperfactory.cs
- BStrWrapper.cs
- SrgsItemList.cs
- UniqueConstraint.cs
- RequestStatusBarUpdateEventArgs.cs
- EventArgs.cs
- Slider.cs
- AuthenticateEventArgs.cs
- NullRuntimeConfig.cs
- DataGridDetailsPresenter.cs
- XmlReflectionMember.cs
- BoundColumn.cs
- FontEmbeddingManager.cs
- Int32CAMarshaler.cs
- CheckBox.cs
- OuterGlowBitmapEffect.cs
- File.cs
- EntityDataSourceDataSelection.cs
- Part.cs
- PathFigure.cs
- ArithmeticException.cs
- CustomErrorsSection.cs
- IResourceProvider.cs
- SslStream.cs
- Bitmap.cs
- ProjectionPathBuilder.cs
- PolyBezierSegment.cs
- SmtpNegotiateAuthenticationModule.cs
- __TransparentProxy.cs
- ToolStripActionList.cs
- ComplexPropertyEntry.cs
- AsymmetricKeyExchangeFormatter.cs
- FigureHelper.cs
- XNodeSchemaApplier.cs
- StandardBindingOptionalReliableSessionElement.cs
- TimelineCollection.cs
- CompilerState.cs
- AddingNewEventArgs.cs
- SoapCodeExporter.cs
- LoginUtil.cs
- Command.cs
- DelegateBodyWriter.cs
- x509store.cs
- PnrpPeerResolver.cs
- SessionStateSection.cs
- DataGrid.cs
- KeyFrames.cs
- ScriptModule.cs
- XmlAtomErrorReader.cs
- NativeRightsManagementAPIsStructures.cs
- IndexerNameAttribute.cs
- ZipIOZip64EndOfCentralDirectoryBlock.cs
- SmiMetaDataProperty.cs
- XsltArgumentList.cs
- InputDevice.cs
- ThreadAbortException.cs
- AssemblyGen.cs
- DaylightTime.cs
- PeerFlooder.cs
- RestHandlerFactory.cs
- IssuanceTokenProviderBase.cs
- DataGridViewRowCollection.cs
- XmlWellformedWriter.cs
- Style.cs
- ExceptionTrace.cs
- SqlDataSourceStatusEventArgs.cs
- ListViewCommandEventArgs.cs
- Pair.cs
- CultureInfoConverter.cs
- CuspData.cs
- FamilyCollection.cs
- ConstrainedDataObject.cs
- CompilerScope.Storage.cs
- RadialGradientBrush.cs
- keycontainerpermission.cs
- DesignBindingPropertyDescriptor.cs
- UnhandledExceptionEventArgs.cs
- StreamWriter.cs
- PropertyPathWorker.cs
- RuleSettingsCollection.cs
- DbDataRecord.cs
- FormsIdentity.cs
- HistoryEventArgs.cs
- PageEventArgs.cs
- X509CertificateInitiatorServiceCredential.cs