Code:
/ FX-1434 / FX-1434 / 1.0 / untmp / whidbey / REDBITS / 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); } } }
Link Menu
This book is available now!
Buy at Amazon US or
Buy at Amazon UK
- SpeechEvent.cs
- DataGridViewTopLeftHeaderCell.cs
- FontWeight.cs
- BufferedGraphicsContext.cs
- TypeConvertions.cs
- Validator.cs
- RealProxy.cs
- RoleManagerSection.cs
- StatusBarDrawItemEvent.cs
- InProcStateClientManager.cs
- ExceptionHandler.cs
- ZipIOZip64EndOfCentralDirectoryBlock.cs
- UnionCodeGroup.cs
- IListConverters.cs
- RootProfilePropertySettingsCollection.cs
- EditorPartChrome.cs
- CanonicalXml.cs
- XmlConvert.cs
- LookupBindingPropertiesAttribute.cs
- TextAnchor.cs
- _HelperAsyncResults.cs
- ServerValidateEventArgs.cs
- SelectionPatternIdentifiers.cs
- BamlReader.cs
- FileDetails.cs
- WebPartUtil.cs
- FixedSOMElement.cs
- SoapEnvelopeProcessingElement.cs
- DbConnectionStringBuilder.cs
- WindowsScrollBarBits.cs
- SmiRecordBuffer.cs
- ButtonBaseAdapter.cs
- TextFragmentEngine.cs
- ToolStripPanelDesigner.cs
- SoapAttributeAttribute.cs
- ProjectionPlan.cs
- TreeNodeBinding.cs
- ReadOnlyCollection.cs
- FontDriver.cs
- XamlBrushSerializer.cs
- DataGridViewComboBoxCell.cs
- SafeFindHandle.cs
- SqlRecordBuffer.cs
- KerberosSecurityTokenParameters.cs
- EditorPartCollection.cs
- PointKeyFrameCollection.cs
- TextContainerChangeEventArgs.cs
- XpsThumbnail.cs
- DataGridRelationshipRow.cs
- FixedTextBuilder.cs
- TreeNode.cs
- ComponentCollection.cs
- ConfigXmlAttribute.cs
- DesignerGeometryHelper.cs
- XsltFunctions.cs
- UnitControl.cs
- EDesignUtil.cs
- MDIClient.cs
- NativeMethods.cs
- GraphicsContext.cs
- InstancePersistence.cs
- FileDataSourceCache.cs
- SatelliteContractVersionAttribute.cs
- TableProviderWrapper.cs
- RenderCapability.cs
- DefaultParameterValueAttribute.cs
- ProgressiveCrcCalculatingStream.cs
- TrustLevel.cs
- DateTimeConstantAttribute.cs
- ResourceDisplayNameAttribute.cs
- IImplicitResourceProvider.cs
- SchemaTypeEmitter.cs
- Attributes.cs
- ReleaseInstanceMode.cs
- ListDictionaryInternal.cs
- InternalCompensate.cs
- DecoratedNameAttribute.cs
- DatagridviewDisplayedBandsData.cs
- DataPagerFieldCollection.cs
- FormViewInsertedEventArgs.cs
- FontInfo.cs
- DecoderFallback.cs
- Delegate.cs
- UpdatePanelControlTrigger.cs
- HostedTransportConfigurationBase.cs
- ImageField.cs
- DataControlButton.cs
- Quaternion.cs
- SchemaNames.cs
- FileSystemWatcher.cs
- MimePart.cs
- InternalControlCollection.cs
- NavigationPropertyEmitter.cs
- PerformanceCounterPermission.cs
- ConnectionConsumerAttribute.cs
- Pair.cs
- TextBox.cs
- Utils.cs
- ConfigurationSettings.cs
- EntityProxyTypeInfo.cs