Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / 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
- LayoutDump.cs
- HttpContext.cs
- DelegatedStream.cs
- ListParagraph.cs
- ResumeStoryboard.cs
- XPathNavigator.cs
- PeerApplication.cs
- ObjectListShowCommandsEventArgs.cs
- ControlFilterExpression.cs
- AnnotationResourceChangedEventArgs.cs
- PersistenceTypeAttribute.cs
- AppModelKnownContentFactory.cs
- EventProvider.cs
- LinkedResource.cs
- SafeNativeMethods.cs
- RolePrincipal.cs
- DBDataPermission.cs
- TimelineCollection.cs
- EasingKeyFrames.cs
- ImageAnimator.cs
- FixedTextView.cs
- GetPageCompletedEventArgs.cs
- PageAdapter.cs
- UnaryNode.cs
- HwndSourceParameters.cs
- LambdaCompiler.Logical.cs
- CultureTable.cs
- ReversePositionQuery.cs
- ZipIOBlockManager.cs
- XmlSchemaSet.cs
- RestrictedTransactionalPackage.cs
- PagesSection.cs
- ContainerVisual.cs
- FileDataSourceCache.cs
- InlineUIContainer.cs
- namescope.cs
- InkCanvasInnerCanvas.cs
- FixedNode.cs
- UIElement.cs
- DetailsViewModeEventArgs.cs
- DoubleAnimationUsingPath.cs
- ConfigurationManagerInternal.cs
- DataKey.cs
- Gdiplus.cs
- RightsManagementEncryptedStream.cs
- ProcessModule.cs
- StatementContext.cs
- NonBatchDirectoryCompiler.cs
- ConstructorNeedsTagAttribute.cs
- SmtpFailedRecipientException.cs
- DefaultPropertiesToSend.cs
- TagPrefixCollection.cs
- OracleColumn.cs
- XmlAggregates.cs
- HttpCapabilitiesEvaluator.cs
- EntityDataSourceUtil.cs
- EmbeddedMailObjectsCollection.cs
- ISO2022Encoding.cs
- PeerChannelFactory.cs
- PresentationAppDomainManager.cs
- ExpandSegment.cs
- ExpressionBuilder.cs
- ResourceDisplayNameAttribute.cs
- HeaderCollection.cs
- IncrementalHitTester.cs
- InternalCache.cs
- RegexWorker.cs
- EntityParameter.cs
- DataBindingCollection.cs
- ValidatorCompatibilityHelper.cs
- BeginEvent.cs
- ShaderEffect.cs
- TransformCryptoHandle.cs
- GeneralTransform3DTo2D.cs
- DelegateBodyWriter.cs
- DropSource.cs
- RoutingTable.cs
- MemoryRecordBuffer.cs
- TextTreeRootNode.cs
- DataSourceView.cs
- __TransparentProxy.cs
- WindowHideOrCloseTracker.cs
- NonBatchDirectoryCompiler.cs
- ServiceNotStartedException.cs
- SafeNativeMethods.cs
- Stream.cs
- ListBoxItemWrapperAutomationPeer.cs
- TypeResolvingOptions.cs
- InfoCardTrace.cs
- SatelliteContractVersionAttribute.cs
- shaperfactoryquerycacheentry.cs
- NotImplementedException.cs
- BitmapPalette.cs
- WindowHideOrCloseTracker.cs
- QilScopedVisitor.cs
- MenuItemAutomationPeer.cs
- PropertyStore.cs
- Predicate.cs
- ListChangedEventArgs.cs
- JobStaple.cs