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
- BypassElementCollection.cs
- TextServicesLoader.cs
- PreservationFileReader.cs
- ObjectStateManagerMetadata.cs
- RelationshipEndCollection.cs
- ipaddressinformationcollection.cs
- PeerNameRecordCollection.cs
- _ConnectOverlappedAsyncResult.cs
- UTF7Encoding.cs
- SynchronizedInputPattern.cs
- WorkflowDesignerMessageFilter.cs
- CharEntityEncoderFallback.cs
- PrimitiveXmlSerializers.cs
- MethodBuilderInstantiation.cs
- DesignerSerializerAttribute.cs
- GeneralTransformCollection.cs
- Metafile.cs
- SourceFilter.cs
- BamlLocalizer.cs
- DesignerOptionService.cs
- InvalidateEvent.cs
- EtwTrace.cs
- SqlTypesSchemaImporter.cs
- ThaiBuddhistCalendar.cs
- RowVisual.cs
- Schedule.cs
- HandlerFactoryWrapper.cs
- mongolianshape.cs
- DataExpression.cs
- XmlSchemaSubstitutionGroup.cs
- Queue.cs
- ModuleBuilder.cs
- HitTestWithPointDrawingContextWalker.cs
- ExtendedPropertyDescriptor.cs
- ContextMarshalException.cs
- panel.cs
- DesignBindingEditor.cs
- CharConverter.cs
- QuadraticBezierSegment.cs
- RenamedEventArgs.cs
- LineUtil.cs
- XmlLanguageConverter.cs
- PropertyPathWorker.cs
- MailAddress.cs
- PageStatePersister.cs
- StaticSiteMapProvider.cs
- PnrpPermission.cs
- WebSysDisplayNameAttribute.cs
- DropDownList.cs
- SizeAnimationUsingKeyFrames.cs
- UnsafeNativeMethods.cs
- EditorZoneBase.cs
- CheckBoxRenderer.cs
- Debugger.cs
- XmlSchemaDatatype.cs
- Pool.cs
- ShortcutKeysEditor.cs
- ScriptModule.cs
- WebPartDisplayMode.cs
- XmlObjectSerializerWriteContextComplex.cs
- SystemResourceHost.cs
- BinaryNode.cs
- ViewLoader.cs
- ExceptionUtil.cs
- TreeViewImageIndexConverter.cs
- SessionPageStatePersister.cs
- AuthenticationManager.cs
- Section.cs
- SecurityTokenSerializer.cs
- SqlWriter.cs
- ObfuscationAttribute.cs
- HostingEnvironmentSection.cs
- _ShellExpression.cs
- InputElement.cs
- FrameworkElement.cs
- InvalidateEvent.cs
- PackagingUtilities.cs
- DiscoveryReference.cs
- QueryComponents.cs
- UpdatePanelTrigger.cs
- OracleMonthSpan.cs
- HostingPreferredMapPath.cs
- TargetException.cs
- SettingsContext.cs
- ReliableMessagingVersionConverter.cs
- SessionStateModule.cs
- Helpers.cs
- ToolStripInSituService.cs
- EdmValidator.cs
- DrawingState.cs
- LinqDataView.cs
- Span.cs
- Source.cs
- PrintDialog.cs
- ObjectCache.cs
- DisposableCollectionWrapper.cs
- Rotation3D.cs
- ParagraphResult.cs
- DocumentOrderComparer.cs
- Wildcard.cs