Code:
/ DotNET / DotNET / 8.0 / untmp / whidbey / REDBITS / 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); } } }
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- IDispatchConstantAttribute.cs
- DoubleLinkList.cs
- ProviderSettings.cs
- StringValidatorAttribute.cs
- NavigationWindow.cs
- FunctionImportElement.cs
- XPathMultyIterator.cs
- DesignTimeVisibleAttribute.cs
- Int32Converter.cs
- WebPartDescriptionCollection.cs
- Control.cs
- Method.cs
- ContentElementCollection.cs
- MessagingDescriptionAttribute.cs
- SessionStateSection.cs
- VirtualPathUtility.cs
- TextSerializer.cs
- DefaultSerializationProviderAttribute.cs
- XmlDataSourceNodeDescriptor.cs
- WebScriptEnablingBehavior.cs
- FilteredAttributeCollection.cs
- InstanceDescriptor.cs
- CryptoApi.cs
- OrderByLifter.cs
- WebServiceData.cs
- Listbox.cs
- ScrollData.cs
- RenderCapability.cs
- WindowsFormsHostAutomationPeer.cs
- DataKeyCollection.cs
- SqlDataSourceAdvancedOptionsForm.cs
- DataTransferEventArgs.cs
- SafeMarshalContext.cs
- Literal.cs
- DelegateTypeInfo.cs
- SecurityUniqueId.cs
- DataServiceStreamResponse.cs
- ToolstripProfessionalRenderer.cs
- CodeDirectionExpression.cs
- ConfigXmlAttribute.cs
- FormViewDesigner.cs
- DataServiceConfiguration.cs
- BinaryUtilClasses.cs
- CfgSemanticTag.cs
- HttpGetClientProtocol.cs
- ToolStripDropTargetManager.cs
- InkCanvasSelectionAdorner.cs
- Journaling.cs
- CDSCollectionETWBCLProvider.cs
- PreDigestedSignedInfo.cs
- PageFunction.cs
- CatalogPartCollection.cs
- MobileControlPersister.cs
- WebBrowserContainer.cs
- loginstatus.cs
- SpellerInterop.cs
- XmlSchema.cs
- InputScopeManager.cs
- NotSupportedException.cs
- EventPropertyMap.cs
- DateTimeSerializationSection.cs
- DesignerActionMethodItem.cs
- StorageEntitySetMapping.cs
- VisualBrush.cs
- SliderAutomationPeer.cs
- ImagingCache.cs
- TdsParserHelperClasses.cs
- MessageBox.cs
- EncoderExceptionFallback.cs
- BuildProvidersCompiler.cs
- PackageDigitalSignature.cs
- DataGridItemEventArgs.cs
- TextTreeNode.cs
- SynchronizedKeyedCollection.cs
- SnapLine.cs
- BoundColumn.cs
- JsonUriDataContract.cs
- SoapReflectionImporter.cs
- BindingMemberInfo.cs
- IdlingCommunicationPool.cs
- HttpCacheVaryByContentEncodings.cs
- DataGridViewCheckBoxCell.cs
- XmlQueryType.cs
- WebPartDisplayModeCollection.cs
- DeferredSelectedIndexReference.cs
- HttpChannelBindingToken.cs
- HttpRequestWrapper.cs
- TcpServerChannel.cs
- EntityType.cs
- CfgParser.cs
- BamlLocalizableResource.cs
- DockPanel.cs
- DataControlCommands.cs
- ConnectionPointGlyph.cs
- ISAPIRuntime.cs
- VarRemapper.cs
- TextWriter.cs
- XmlSchemaAnnotated.cs
- SQLMoneyStorage.cs
- SubMenuStyleCollection.cs