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
- ManipulationStartingEventArgs.cs
- CatalogPartCollection.cs
- InfoCardBaseException.cs
- ConstructorNeedsTagAttribute.cs
- DispatcherEventArgs.cs
- SqlBinder.cs
- IChannel.cs
- ExternalFile.cs
- OracleBFile.cs
- ProxyFragment.cs
- ClusterRegistryConfigurationProvider.cs
- HtmlTableRowCollection.cs
- MdImport.cs
- GCHandleCookieTable.cs
- EventLog.cs
- ConfigurationManager.cs
- SqlNodeTypeOperators.cs
- DropShadowEffect.cs
- ChtmlCommandAdapter.cs
- SoapCodeExporter.cs
- CalculatedColumn.cs
- RequestCacheValidator.cs
- ConfigXmlDocument.cs
- MouseGesture.cs
- ResXDataNode.cs
- String.cs
- RegexCharClass.cs
- Line.cs
- DefaultValidator.cs
- MobileListItemCollection.cs
- ProjectedWrapper.cs
- IntSecurity.cs
- WeakRefEnumerator.cs
- ContextQuery.cs
- Command.cs
- CompareInfo.cs
- AppDomainShutdownMonitor.cs
- WinFormsUtils.cs
- ArrangedElementCollection.cs
- UriParserTemplates.cs
- ProvideValueServiceProvider.cs
- SecurityAccessDeniedException.cs
- XmlLoader.cs
- SessionPageStatePersister.cs
- TypeName.cs
- FirstQueryOperator.cs
- StatusStrip.cs
- KerberosSecurityTokenProvider.cs
- SmiEventSink_Default.cs
- TagPrefixInfo.cs
- Attributes.cs
- SQLInt64.cs
- SectionUpdates.cs
- BulletedListEventArgs.cs
- BaseTemplateParser.cs
- HorizontalAlignConverter.cs
- StandardOleMarshalObject.cs
- InstalledFontCollection.cs
- HuffModule.cs
- StringUtil.cs
- ToolStripRendererSwitcher.cs
- XmlSchemaExternal.cs
- DataGridAutoGeneratingColumnEventArgs.cs
- RenderingEventArgs.cs
- PropertyGeneratedEventArgs.cs
- DesignTimeType.cs
- QuadraticBezierSegment.cs
- SelectionWordBreaker.cs
- WebPartHeaderCloseVerb.cs
- ComponentManagerBroker.cs
- RSAOAEPKeyExchangeDeformatter.cs
- MD5Cng.cs
- Figure.cs
- XmlBinaryReader.cs
- RecommendedAsConfigurableAttribute.cs
- dataSvcMapFileLoader.cs
- UrlPropertyAttribute.cs
- WaveHeader.cs
- OLEDB_Enum.cs
- IndentedTextWriter.cs
- ISAPIWorkerRequest.cs
- VoiceChangeEventArgs.cs
- AttachedPropertyBrowsableAttribute.cs
- _SSPIWrapper.cs
- ContentTextAutomationPeer.cs
- DynamicScriptObject.cs
- LoadItemsEventArgs.cs
- SubMenuStyleCollection.cs
- PageWrapper.cs
- RoutedCommand.cs
- EFTableProvider.cs
- ListDataBindEventArgs.cs
- SolidColorBrush.cs
- SafeArrayRankMismatchException.cs
- Win32PrintDialog.cs
- ListBoxDesigner.cs
- ErrorWebPart.cs
- ImageKeyConverter.cs
- DynamicQueryableWrapper.cs
- SafeRightsManagementQueryHandle.cs