Code:
/ Net / Net / 3.5.50727.3053 / DEVDIV / depot / DevDiv / releases / whidbey / netfxsp / 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
- AsyncOperation.cs
- LinkLabelLinkClickedEvent.cs
- _SslStream.cs
- ProvidePropertyAttribute.cs
- DBConnection.cs
- MinimizableAttributeTypeConverter.cs
- MsmqSecureHashAlgorithm.cs
- ProtocolsConfigurationEntry.cs
- WrapPanel.cs
- BitmapVisualManager.cs
- FastEncoderWindow.cs
- TextBreakpoint.cs
- CodeMemberMethod.cs
- Helpers.cs
- CompiledQuery.cs
- PageAction.cs
- Point3DCollection.cs
- ISessionStateStore.cs
- InfoCardCryptoHelper.cs
- ToolStripItemClickedEventArgs.cs
- ProcessInfo.cs
- HttpWriter.cs
- ScrollItemProviderWrapper.cs
- HandlerFactoryCache.cs
- TCPClient.cs
- StructuralComparisons.cs
- StorageEntitySetMapping.cs
- DataRowView.cs
- RectAnimationUsingKeyFrames.cs
- InputBinder.cs
- ChannelManagerHelpers.cs
- EntityDataSourceChangedEventArgs.cs
- ADConnectionHelper.cs
- OLEDB_Enum.cs
- SHA512.cs
- ValidationHelpers.cs
- XmlCustomFormatter.cs
- ShutDownListener.cs
- DefaultWorkflowTransactionService.cs
- DirectoryObjectSecurity.cs
- PropertyNames.cs
- WizardForm.cs
- SmtpLoginAuthenticationModule.cs
- PageAsyncTask.cs
- SelectingProviderEventArgs.cs
- CacheDependency.cs
- MemberDescriptor.cs
- WindowsGraphics.cs
- FilterException.cs
- PathData.cs
- PasswordTextNavigator.cs
- WindowsScrollBarBits.cs
- DataGridHelper.cs
- StyleConverter.cs
- _ConnectStream.cs
- SmtpSpecifiedPickupDirectoryElement.cs
- GlyphsSerializer.cs
- CacheAxisQuery.cs
- OuterGlowBitmapEffect.cs
- DataReceivedEventArgs.cs
- DefaultWorkflowSchedulerService.cs
- XPathArrayIterator.cs
- HMACRIPEMD160.cs
- RightsManagementPermission.cs
- BufferedWebEventProvider.cs
- CacheMemory.cs
- EditingScope.cs
- SQLRoleProvider.cs
- HostingEnvironment.cs
- AttachedPropertyBrowsableAttribute.cs
- GetImportedCardRequest.cs
- RenderingBiasValidation.cs
- sitestring.cs
- HighlightVisual.cs
- SqlUdtInfo.cs
- SafeRegistryHandle.cs
- CreateUserErrorEventArgs.cs
- XmlElementList.cs
- Section.cs
- WindowsGraphics2.cs
- MappedMetaModel.cs
- QfeChecker.cs
- SecUtil.cs
- FixedSOMSemanticBox.cs
- DeploymentSectionCache.cs
- RsaSecurityKey.cs
- EdmScalarPropertyAttribute.cs
- Table.cs
- BaseDataList.cs
- GridViewEditEventArgs.cs
- ScriptComponentDescriptor.cs
- ChildTable.cs
- ExpressionPrinter.cs
- HtmlLink.cs
- FormsIdentity.cs
- BindingEntityInfo.cs
- CodeSnippetStatement.cs
- ItemDragEvent.cs
- Parameter.cs
- MediaSystem.cs