Code:
/ Dotnetfx_Win7_3.5.1 / Dotnetfx_Win7_3.5.1 / 3.5.1 / DEVDIV / depot / DevDiv / releases / whidbey / NetFXspW7 / 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); } } } // File provided for Reference Use Only by Microsoft Corporation (c) 2007. //------------------------------------------------------------------------------ //// 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
- FileSystemWatcher.cs
- VectorAnimationUsingKeyFrames.cs
- FileChangesMonitor.cs
- MsmqInputChannelListener.cs
- FocusWithinProperty.cs
- Int16.cs
- followingsibling.cs
- OrderByBuilder.cs
- EventDescriptor.cs
- DataGridViewButtonColumn.cs
- Validator.cs
- CodeBlockBuilder.cs
- CheckBox.cs
- Decorator.cs
- ErrorEventArgs.cs
- DurableEnlistmentState.cs
- ListViewInsertEventArgs.cs
- PriorityItem.cs
- Splitter.cs
- TemplateManager.cs
- ButtonFieldBase.cs
- ThreadInterruptedException.cs
- TextServicesPropertyRanges.cs
- RadialGradientBrush.cs
- SweepDirectionValidation.cs
- MergeLocalizationDirectives.cs
- CurrencyManager.cs
- LocalsItemDescription.cs
- SiteMapNodeItem.cs
- DataGridViewSortCompareEventArgs.cs
- _UriTypeConverter.cs
- SqlDataSourceView.cs
- DataServiceHostFactory.cs
- CornerRadiusConverter.cs
- StatusBarItemAutomationPeer.cs
- SoapAttributeOverrides.cs
- TrueReadOnlyCollection.cs
- ResourcesChangeInfo.cs
- UniqueIdentifierService.cs
- XPathParser.cs
- SchemaImporterExtension.cs
- SafeMemoryMappedFileHandle.cs
- ScriptControlDescriptor.cs
- RSAOAEPKeyExchangeFormatter.cs
- WorkflowViewStateService.cs
- Int32EqualityComparer.cs
- ExtentKey.cs
- SimpleTextLine.cs
- AutomationElementCollection.cs
- MetadataSerializer.cs
- PathNode.cs
- AppModelKnownContentFactory.cs
- CfgRule.cs
- IisTraceListener.cs
- OptionalRstParameters.cs
- UInt16.cs
- RequestValidator.cs
- DurableInstance.cs
- Accessors.cs
- JapaneseLunisolarCalendar.cs
- XmlNavigatorStack.cs
- Preprocessor.cs
- WeakRefEnumerator.cs
- Rule.cs
- Preprocessor.cs
- InputManager.cs
- parserscommon.cs
- PersonalizationProvider.cs
- DbModificationClause.cs
- ColumnMap.cs
- InfoCardCryptoHelper.cs
- PassportAuthenticationEventArgs.cs
- PropertyPushdownHelper.cs
- StateRuntime.cs
- SchemaTypeEmitter.cs
- WindowsToolbarAsMenu.cs
- arclist.cs
- BindableAttribute.cs
- XmlNavigatorStack.cs
- ProcessHostServerConfig.cs
- MailMessageEventArgs.cs
- FullTextState.cs
- MarkupExtensionReturnTypeAttribute.cs
- NativeCompoundFileAPIs.cs
- Interlocked.cs
- WebZone.cs
- RegularExpressionValidator.cs
- FlowDocumentView.cs
- DocumentGridPage.cs
- WriteTimeStream.cs
- StorageModelBuildProvider.cs
- NamespaceExpr.cs
- CryptoApi.cs
- LinqMaximalSubtreeNominator.cs
- JsonXmlDataContract.cs
- CodeStatementCollection.cs
- DropShadowBitmapEffect.cs
- ItemContainerGenerator.cs
- OdbcEnvironment.cs
- DependencyProperty.cs