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
- HttpProfileBase.cs
- RtType.cs
- AsyncContentLoadedEventArgs.cs
- X509RecipientCertificateClientElement.cs
- Evaluator.cs
- FontStyle.cs
- ReaderWriterLockWrapper.cs
- BindingGroup.cs
- TypeSystem.cs
- VisualBasicDesignerHelper.cs
- MembershipPasswordException.cs
- SerialErrors.cs
- ToolStripDropDownClosedEventArgs.cs
- UserControlCodeDomTreeGenerator.cs
- CompilerScope.Storage.cs
- CommandSet.cs
- PersistChildrenAttribute.cs
- Win32SafeHandles.cs
- XmlChildEnumerator.cs
- DbDataReader.cs
- EventListener.cs
- DES.cs
- XPathNavigatorKeyComparer.cs
- ListViewDataItem.cs
- GenericUriParser.cs
- Roles.cs
- ItemAutomationPeer.cs
- SharedPersonalizationStateInfo.cs
- LabelTarget.cs
- DrawingImage.cs
- CompressStream.cs
- HashRepartitionEnumerator.cs
- EdmToObjectNamespaceMap.cs
- NavigationHelper.cs
- SafeCryptContextHandle.cs
- DivideByZeroException.cs
- ServiceContractGenerator.cs
- CuspData.cs
- Container.cs
- FieldToken.cs
- RepeatInfo.cs
- PointLightBase.cs
- FixedPageStructure.cs
- DataGridViewRowHeightInfoPushedEventArgs.cs
- SqlServer2KCompatibilityCheck.cs
- XmlWriterDelegator.cs
- Thread.cs
- ToolStripDropDownClosingEventArgs.cs
- SemaphoreFullException.cs
- Int32AnimationBase.cs
- XPathSelfQuery.cs
- LocalizedNameDescriptionPair.cs
- GenericTypeParameterConverter.cs
- XmlSchemaSimpleTypeRestriction.cs
- ImageListUtils.cs
- NativeMethods.cs
- StartUpEventArgs.cs
- DispatcherHookEventArgs.cs
- NameSpaceExtractor.cs
- CaseInsensitiveHashCodeProvider.cs
- Symbol.cs
- UidPropertyAttribute.cs
- WindowsListViewGroupHelper.cs
- ReadOnlyHierarchicalDataSource.cs
- XmlCharacterData.cs
- XmlWriterSettings.cs
- WebServiceHostFactory.cs
- DocumentViewerBaseAutomationPeer.cs
- DrawingContextWalker.cs
- MenuAutoFormat.cs
- SynchronizationLockException.cs
- cache.cs
- Keywords.cs
- ServicePointManager.cs
- NotImplementedException.cs
- ClientCredentialsElement.cs
- TaiwanLunisolarCalendar.cs
- SimpleApplicationHost.cs
- XmlAttributeHolder.cs
- SwitchLevelAttribute.cs
- ObjectConverter.cs
- Transform3DCollection.cs
- ExceptionHelpers.cs
- DesignerFrame.cs
- CollectionView.cs
- PageRanges.cs
- HttpsHostedTransportConfiguration.cs
- LoginViewDesigner.cs
- LongValidator.cs
- FilterException.cs
- ValidatedMobileControlConverter.cs
- XmlEncoding.cs
- SQLCharsStorage.cs
- FtpRequestCacheValidator.cs
- DbDataAdapter.cs
- SchemaImporter.cs
- QilFunction.cs
- ZoneButton.cs
- TraceContextRecord.cs
- UIElement.cs