Code:
/ Dotnetfx_Vista_SP2 / Dotnetfx_Vista_SP2 / 8.0.50727.4016 / DEVDIV / depot / DevDiv / releases / whidbey / NetFxQFE / 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
- UniqueIdentifierService.cs
- JavaScriptString.cs
- TextContainerHelper.cs
- WebCategoryAttribute.cs
- ComplexObject.cs
- UnsafeNativeMethods.cs
- ComplexBindingPropertiesAttribute.cs
- CustomWebEventKey.cs
- SafeIUnknown.cs
- PropertyEntry.cs
- TabControlEvent.cs
- SqlInternalConnection.cs
- ConditionalAttribute.cs
- RefreshEventArgs.cs
- BrowserDefinition.cs
- ListBoxChrome.cs
- CodeExpressionCollection.cs
- RenderTargetBitmap.cs
- TransactionManager.cs
- InvalidTimeZoneException.cs
- Size.cs
- TextEffectCollection.cs
- ValidationErrorCollection.cs
- OdbcErrorCollection.cs
- TextElementCollectionHelper.cs
- InteropAutomationProvider.cs
- MeasureData.cs
- EmptyStringExpandableObjectConverter.cs
- SocketSettings.cs
- ViewCellRelation.cs
- AnnouncementInnerClient11.cs
- CompletionCallbackWrapper.cs
- SafeCryptContextHandle.cs
- FileRecordSequenceCompletedAsyncResult.cs
- CatalogPartChrome.cs
- HtmlHead.cs
- SHA1CryptoServiceProvider.cs
- ColorAnimationBase.cs
- SimpleApplicationHost.cs
- AbsoluteQuery.cs
- FocusTracker.cs
- FindResponse.cs
- WindowsPrincipal.cs
- TraceSection.cs
- XPathSelectionIterator.cs
- OdbcFactory.cs
- HMACSHA1.cs
- StringFunctions.cs
- SmiMetaDataProperty.cs
- RegisteredScript.cs
- ExtendedPropertyCollection.cs
- UIElement3D.cs
- SafeNativeMethods.cs
- ProxyManager.cs
- TimeSpanStorage.cs
- MetaModel.cs
- embossbitmapeffect.cs
- OdbcCommand.cs
- StrongNameSignatureInformation.cs
- ScalarType.cs
- TargetInvocationException.cs
- DataBindingHandlerAttribute.cs
- DataSourceXmlAttributeAttribute.cs
- PrePrepareMethodAttribute.cs
- DocumentPage.cs
- ControlBindingsCollection.cs
- MenuTracker.cs
- SocketElement.cs
- MailHeaderInfo.cs
- DetailsView.cs
- TemplatePropertyEntry.cs
- ReachDocumentReferenceSerializer.cs
- SystemColors.cs
- ProfileGroupSettings.cs
- XmlSchemaSubstitutionGroup.cs
- DataGridColumnHeaderAutomationPeer.cs
- ContainerCodeDomSerializer.cs
- DataDocumentXPathNavigator.cs
- ModifiableIteratorCollection.cs
- DelegatedStream.cs
- DisplayNameAttribute.cs
- DocumentSequenceHighlightLayer.cs
- UndoManager.cs
- SvcMapFile.cs
- ExpressionBuilder.cs
- Comparer.cs
- CollectionContainer.cs
- UniqueCodeIdentifierScope.cs
- FieldDescriptor.cs
- SourceLineInfo.cs
- SvcMapFileLoader.cs
- CompModSwitches.cs
- DataList.cs
- ActivityMarkupSerializationProvider.cs
- OnOperation.cs
- XmlDataProvider.cs
- ImageListStreamer.cs
- WebPageTraceListener.cs
- IxmlLineInfo.cs
- CursorConverter.cs