Code:
/ 4.0 / 4.0 / 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. //------------------------------------------------------------------------------ //// 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
- DataSetUtil.cs
- Size.cs
- MsmqIntegrationBinding.cs
- CheckBoxDesigner.cs
- ProfileInfo.cs
- ServerValidateEventArgs.cs
- BehaviorEditorPart.cs
- StructuredType.cs
- TypeSystem.cs
- AlternateView.cs
- ImpersonationOption.cs
- StaticTextPointer.cs
- VirtualizingPanel.cs
- ResourceType.cs
- SharingService.cs
- MiniLockedBorderGlyph.cs
- ServiceProviders.cs
- EditorPartCollection.cs
- PropertyToken.cs
- SpotLight.cs
- TextEditorSpelling.cs
- RepeatBehaviorConverter.cs
- Statements.cs
- Matrix.cs
- TdsValueSetter.cs
- IntegerValidatorAttribute.cs
- CqlParser.cs
- SurrogateSelector.cs
- ModelTypeConverter.cs
- Mapping.cs
- RTTypeWrapper.cs
- MultiBinding.cs
- SafeNativeMethodsOther.cs
- CharacterHit.cs
- ObservableDictionary.cs
- UdpConstants.cs
- NetSectionGroup.cs
- AppDomain.cs
- RadioButton.cs
- AttributedMetaModel.cs
- CompressStream.cs
- ResXResourceReader.cs
- AppSecurityManager.cs
- BaseDataList.cs
- CopyOnWriteList.cs
- SqlCacheDependencyDatabase.cs
- SettingsAttributes.cs
- ListView.cs
- DoubleAnimationBase.cs
- InternalsVisibleToAttribute.cs
- TableLayoutPanel.cs
- WaveHeader.cs
- CodeIndexerExpression.cs
- EventLogEntryCollection.cs
- ValidatedControlConverter.cs
- RandomNumberGenerator.cs
- _AcceptOverlappedAsyncResult.cs
- Debugger.cs
- SByteConverter.cs
- EntityDataSourceContextDisposingEventArgs.cs
- QueryStringParameter.cs
- SemanticBasicElement.cs
- IndexOutOfRangeException.cs
- TemplatePropertyEntry.cs
- ObjectItemCollection.cs
- HtmlTableRow.cs
- UnknownBitmapEncoder.cs
- CodeIdentifiers.cs
- PropertyValueChangedEvent.cs
- TraceContext.cs
- ComponentCollection.cs
- Preprocessor.cs
- XmlUtil.cs
- ADMembershipProvider.cs
- PropertyEntry.cs
- PolicyLevel.cs
- HtmlInputCheckBox.cs
- HMACSHA1.cs
- MSHTMLHost.cs
- UpdateException.cs
- MetabaseServerConfig.cs
- MouseActionValueSerializer.cs
- FixedTextView.cs
- ProviderUtil.cs
- WindowsContainer.cs
- GifBitmapDecoder.cs
- PageContentCollection.cs
- PerfCounterSection.cs
- SlipBehavior.cs
- ProgressBar.cs
- RangeBaseAutomationPeer.cs
- AdCreatedEventArgs.cs
- TemplateAction.cs
- AssemblyHash.cs
- PixelShader.cs
- FormClosingEvent.cs
- PriorityBinding.cs
- TextAdaptor.cs
- ByteStorage.cs
- MarshalDirectiveException.cs