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
- ExitEventArgs.cs
- WindowsAuthenticationEventArgs.cs
- SqlConnectionManager.cs
- BufferedStream.cs
- PasswordTextContainer.cs
- Rect3D.cs
- CompositeFontFamily.cs
- DisposableCollectionWrapper.cs
- SerializationSectionGroup.cs
- SurrogateDataContract.cs
- RelationshipType.cs
- RenderData.cs
- IsolatedStorageSecurityState.cs
- JsonFormatGeneratorStatics.cs
- ViewStateException.cs
- BaseValidator.cs
- BaseAsyncResult.cs
- WeakReferenceKey.cs
- KeyFrames.cs
- SoapCommonClasses.cs
- ClientSponsor.cs
- WebPartDisplayModeEventArgs.cs
- ListViewEditEventArgs.cs
- DeploymentSectionCache.cs
- SelectionChangedEventArgs.cs
- CodeDelegateCreateExpression.cs
- Debug.cs
- InheritanceRules.cs
- SqlUserDefinedTypeAttribute.cs
- UnsafeNativeMethods.cs
- RoleServiceManager.cs
- ReceiveErrorHandling.cs
- ExpandCollapseProviderWrapper.cs
- MarkupExtensionSerializer.cs
- RawAppCommandInputReport.cs
- ConfigurationErrorsException.cs
- IIS7WorkerRequest.cs
- StringValidatorAttribute.cs
- ControlAdapter.cs
- TypeUnloadedException.cs
- SrgsElementList.cs
- SqlVisitor.cs
- KeyValuePairs.cs
- MediaContext.cs
- SqlBulkCopyColumnMappingCollection.cs
- PriorityItem.cs
- OpenFileDialog.cs
- VirtualizingPanel.cs
- WebDisplayNameAttribute.cs
- ShapeTypeface.cs
- wgx_render.cs
- TextInfo.cs
- AutomationEventArgs.cs
- TcpHostedTransportConfiguration.cs
- PointConverter.cs
- listitem.cs
- ADConnectionHelper.cs
- GridView.cs
- MethodBody.cs
- TextEncodedRawTextWriter.cs
- XmlSignatureProperties.cs
- PrivilegedConfigurationManager.cs
- LabelAutomationPeer.cs
- StreamReader.cs
- XmlUtilWriter.cs
- Color.cs
- ReachObjectContext.cs
- RowToFieldTransformer.cs
- SizeConverter.cs
- KnowledgeBase.cs
- AppDomain.cs
- XmlDomTextWriter.cs
- SafeBitVector32.cs
- InputLanguage.cs
- Mutex.cs
- QuaternionIndependentAnimationStorage.cs
- PageCatalogPart.cs
- parserscommon.cs
- IPipelineRuntime.cs
- DecryptedHeader.cs
- Matrix.cs
- KeyGestureValueSerializer.cs
- SmiConnection.cs
- FileDialog_Vista.cs
- Function.cs
- CapiSymmetricAlgorithm.cs
- PieceDirectory.cs
- Configuration.cs
- DeviceContext.cs
- errorpatternmatcher.cs
- CallSiteBinder.cs
- FactoryId.cs
- ComPlusServiceHost.cs
- RoutingEndpointTrait.cs
- Splitter.cs
- ControlBuilder.cs
- DataGridViewCellValidatingEventArgs.cs
- SchemaImporterExtensionElement.cs
- ProtocolsConfigurationEntry.cs
- DocumentPaginator.cs