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
- XmlObjectSerializerContext.cs
- GridItemProviderWrapper.cs
- WindowsGraphics.cs
- CopyAction.cs
- DetailsViewCommandEventArgs.cs
- ExpressionBindings.cs
- ImageClickEventArgs.cs
- XmlSchemaSimpleTypeList.cs
- EpmContentDeSerializer.cs
- CounterCreationDataCollection.cs
- GcSettings.cs
- keycontainerpermission.cs
- CollectionViewProxy.cs
- BindingMemberInfo.cs
- ColorDialog.cs
- TrackPoint.cs
- SessionKeyExpiredException.cs
- MouseEventArgs.cs
- SvcMapFileSerializer.cs
- ControlParameter.cs
- ResolveMatchesApril2005.cs
- XPathBuilder.cs
- ExpandableObjectConverter.cs
- EntitySetBase.cs
- Socket.cs
- TraceSwitch.cs
- TreeViewHitTestInfo.cs
- PropertyDescriptorCollection.cs
- DoubleAnimationUsingKeyFrames.cs
- securitycriticaldata.cs
- SplayTreeNode.cs
- WebReferencesBuildProvider.cs
- ServiceRouteHandler.cs
- SqlDataReader.cs
- XPathMessageFilterElement.cs
- PerfCounters.cs
- PerformanceCounterCategory.cs
- ZipFileInfoCollection.cs
- InputLangChangeRequestEvent.cs
- InstanceCreationEditor.cs
- EntityReference.cs
- OperationCanceledException.cs
- SoapReflectionImporter.cs
- WindowsTooltip.cs
- CompositionTarget.cs
- Attributes.cs
- StrongNameMembershipCondition.cs
- DirectoryObjectSecurity.cs
- NavigatorInput.cs
- CompressStream.cs
- Brushes.cs
- DbSource.cs
- DataSourceProvider.cs
- FlowDocumentScrollViewerAutomationPeer.cs
- MenuItemBinding.cs
- GeneralTransformGroup.cs
- TimeSpan.cs
- ProjectionPath.cs
- SBCSCodePageEncoding.cs
- IncrementalHitTester.cs
- ItemsPanelTemplate.cs
- ClientEventManager.cs
- ConfigurationFileMap.cs
- Imaging.cs
- ObjectListCommandsPage.cs
- IncrementalHitTester.cs
- ThousandthOfEmRealPoints.cs
- ColumnTypeConverter.cs
- UniqueIdentifierService.cs
- SqlProviderUtilities.cs
- DbConnectionFactory.cs
- MinimizableAttributeTypeConverter.cs
- List.cs
- TreeViewImageIndexConverter.cs
- ProfileGroupSettingsCollection.cs
- AccessText.cs
- RepeaterCommandEventArgs.cs
- TextMessageEncodingElement.cs
- UserControl.cs
- TextRunCache.cs
- DataBindEngine.cs
- TiffBitmapEncoder.cs
- uribuilder.cs
- ConfigXmlReader.cs
- HelpInfo.cs
- CngKey.cs
- TrackingSection.cs
- ApplicationManager.cs
- LoginView.cs
- _IPv6Address.cs
- AnimationException.cs
- ProxyFragment.cs
- EditorAttributeInfo.cs
- WithStatement.cs
- SQLBytes.cs
- CompositeFontFamily.cs
- StringCollection.cs
- DataComponentNameHandler.cs
- ObjectPropertyMapping.cs
- EntitySqlException.cs