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
- PackUriHelper.cs
- TableParagraph.cs
- HwndStylusInputProvider.cs
- VisualBrush.cs
- XAMLParseException.cs
- SafeCryptoHandles.cs
- SQLGuidStorage.cs
- ProgressiveCrcCalculatingStream.cs
- TransactionValidationBehavior.cs
- FunctionCommandText.cs
- ListViewDeletedEventArgs.cs
- IRCollection.cs
- QilGeneratorEnv.cs
- ModelTreeManager.cs
- documentsequencetextpointer.cs
- SelectionChangedEventArgs.cs
- UTF7Encoding.cs
- ConstructorBuilder.cs
- StateMachineAction.cs
- DetailsViewDesigner.cs
- TranslateTransform3D.cs
- DictionaryKeyPropertyAttribute.cs
- ButtonField.cs
- MissingMemberException.cs
- HttpInputStream.cs
- WaitHandleCannotBeOpenedException.cs
- SecurityUtils.cs
- RtfToXamlLexer.cs
- Rect3DConverter.cs
- HtmlEncodedRawTextWriter.cs
- GeometryValueSerializer.cs
- TableLayoutPanel.cs
- ConfigurationSettings.cs
- ReferenceEqualityComparer.cs
- XamlTemplateSerializer.cs
- Stackframe.cs
- MailAddress.cs
- Rotation3D.cs
- Animatable.cs
- UriExt.cs
- RequestUriProcessor.cs
- SafeRightsManagementEnvironmentHandle.cs
- ExecutionEngineException.cs
- ProfileParameter.cs
- RequestFactory.cs
- PackagingUtilities.cs
- FontStyleConverter.cs
- CookieProtection.cs
- SiteOfOriginPart.cs
- BaseCodeDomTreeGenerator.cs
- Internal.cs
- XmlSchemaAnnotated.cs
- DbDataSourceEnumerator.cs
- SchemaSetCompiler.cs
- ObjectListFieldsPage.cs
- StubHelpers.cs
- SqlConnectionManager.cs
- NullableFloatAverageAggregationOperator.cs
- MultipartContentParser.cs
- Avt.cs
- DispatchChannelSink.cs
- WebConvert.cs
- RepeatBehaviorConverter.cs
- Sequence.cs
- AspProxy.cs
- DiagnosticsConfiguration.cs
- COM2AboutBoxPropertyDescriptor.cs
- ScrollContentPresenter.cs
- GeneralTransform2DTo3D.cs
- LocationSectionRecord.cs
- PrtTicket_Editor.cs
- RelationshipConverter.cs
- ViewStateChangedEventArgs.cs
- HGlobalSafeHandle.cs
- MatrixUtil.cs
- listitem.cs
- DependencyObjectPropertyDescriptor.cs
- CatalogPart.cs
- WindowsListViewGroupSubsetLink.cs
- JulianCalendar.cs
- FontInfo.cs
- TypeExtension.cs
- Permission.cs
- GeometryCombineModeValidation.cs
- OracleMonthSpan.cs
- InfoCardRSAPKCS1KeyExchangeFormatter.cs
- ImageDrawing.cs
- VectorCollection.cs
- TextTabProperties.cs
- OutputScope.cs
- FullTrustAssembly.cs
- RightsManagementEncryptionTransform.cs
- TypeLibConverter.cs
- XslException.cs
- ListDictionaryInternal.cs
- DataBoundControlAdapter.cs
- ImpersonationContext.cs
- DataRelationCollection.cs
- ResXResourceWriter.cs
- RegionInfo.cs