Code:
/ 4.0 / 4.0 / untmp / 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.
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- Message.cs
- Win32SafeHandles.cs
- odbcmetadatacolumnnames.cs
- PtsHost.cs
- TagNameToTypeMapper.cs
- PartialTrustVisibleAssembliesSection.cs
- PagedDataSource.cs
- XmlCharCheckingWriter.cs
- SqlProfileProvider.cs
- altserialization.cs
- ContractMethodParameterInfo.cs
- X509KeyIdentifierClauseType.cs
- Fault.cs
- LocalizableAttribute.cs
- ThicknessAnimationBase.cs
- SecurityAccessDeniedException.cs
- SettingsProperty.cs
- AppDomainShutdownMonitor.cs
- TypeTypeConverter.cs
- EventsTab.cs
- DesignerForm.cs
- PlatformNotSupportedException.cs
- TextTreePropertyUndoUnit.cs
- StateItem.cs
- CapacityStreamGeometryContext.cs
- PassportAuthenticationEventArgs.cs
- AssemblyAssociatedContentFileAttribute.cs
- Enum.cs
- SqlDataSourceCache.cs
- AmbientLight.cs
- DataGridViewEditingControlShowingEventArgs.cs
- BitmapSourceSafeMILHandle.cs
- TreeNodeCollection.cs
- FixedSOMElement.cs
- UTF7Encoding.cs
- SqlParameterCollection.cs
- GrammarBuilderBase.cs
- DependencyPropertyDescriptor.cs
- CodeValidator.cs
- PostBackOptions.cs
- OleDbCommand.cs
- IListConverters.cs
- SqlBuilder.cs
- BaseServiceProvider.cs
- _BasicClient.cs
- FormViewRow.cs
- MulticastOption.cs
- TypeInformation.cs
- LiteralControl.cs
- UnsafeNativeMethods.cs
- StylusEventArgs.cs
- SqlRecordBuffer.cs
- SystemBrushes.cs
- GeometryGroup.cs
- SamlAuthorizationDecisionStatement.cs
- TypeDescriptionProviderAttribute.cs
- PasswordPropertyTextAttribute.cs
- _ConnectStream.cs
- BaseUriWithWildcard.cs
- ExtractorMetadata.cs
- MarshalDirectiveException.cs
- SessionState.cs
- ConsumerConnectionPoint.cs
- CreateUserWizard.cs
- StaticContext.cs
- SecuritySessionSecurityTokenProvider.cs
- RealizedColumnsBlock.cs
- XPathAncestorIterator.cs
- DATA_BLOB.cs
- PreservationFileReader.cs
- ViewgenContext.cs
- SecurityPolicySection.cs
- XmlChildNodes.cs
- SecurityRequiresReviewAttribute.cs
- Math.cs
- LinkDescriptor.cs
- InheritanceAttribute.cs
- OrderedDictionary.cs
- RijndaelManagedTransform.cs
- SqlDataSourceConnectionPanel.cs
- SessionIDManager.cs
- TypeDescriptionProvider.cs
- TokenBasedSet.cs
- ResourceLoader.cs
- ListBoxItemAutomationPeer.cs
- SqlDataSourceConfigureSortForm.cs
- XhtmlCssHandler.cs
- DeploymentExceptionMapper.cs
- HtmlInputCheckBox.cs
- PageThemeParser.cs
- ImpersonationContext.cs
- XmlSignatureManifest.cs
- Span.cs
- XPathCompileException.cs
- DesignerVerb.cs
- EmptyImpersonationContext.cs
- SimpleHandlerBuildProvider.cs
- ValidatorCollection.cs
- Site.cs
- ThreadStateException.cs