Merge pull request #29 from cjbush/feature/25-istream_copyto

Fix for #25. Added CopyTo methods to IStream
This commit is contained in:
Jozef Izso 2017-02-16 21:11:09 +01:00 коммит произвёл GitHub
Родитель 230391a3db 9ab51ecc6f
Коммит 577edc8c1b
4 изменённых файлов: 219 добавлений и 0 удалений

Просмотреть файл

@ -341,5 +341,149 @@ namespace SystemInterface.IO
/// </summary> /// </summary>
/// <param name="value">The byte to write to the stream. </param> /// <param name="value">The byte to write to the stream. </param>
void WriteByte(byte value); void WriteByte(byte value);
//
// Summary:
// Reads the bytes from the current stream and writes them to another stream.
//
// Parameters:
// destination:
// The stream to which the contents of the current stream will be copied.
//
// Exceptions:
// T:System.ArgumentNullException:
// destination is null.
//
// T:System.NotSupportedException:
// The current stream does not support reading.-or-destination does not support
// writing.
//
// T:System.ObjectDisposedException:
// Either the current stream or destination were closed before the System.IO.Stream.CopyTo(System.IO.Stream)
// method was called.
//
// T:System.IO.IOException:
// An I/O error occurred.
void CopyTo(IStream destination);
//
// Summary:
// Reads the bytes from the current stream and writes them to another stream, using
// a specified buffer size.
//
// Parameters:
// destination:
// The stream to which the contents of the current stream will be copied.
//
// bufferSize:
// The size of the buffer. This value must be greater than zero. The default size
// is 81920.
//
// Exceptions:
// T:System.ArgumentNullException:
// destination is null.
//
// T:System.ArgumentOutOfRangeException:
// bufferSize is negative or zero.
//
// T:System.NotSupportedException:
// The current stream does not support reading.-or-destination does not support
// writing.
//
// T:System.ObjectDisposedException:
// Either the current stream or destination were closed before the System.IO.Stream.CopyTo(System.IO.Stream)
// method was called.
//
// T:System.IO.IOException:
// An I/O error occurred.
void CopyTo(IStream destination, int bufferSize);
//
// Summary:
// Asynchronously reads the bytes from the current stream and writes them to another
// stream.
//
// Parameters:
// destination:
// The stream to which the contents of the current stream will be copied.
//
// Returns:
// A task that represents the asynchronous copy operation.
//
// Exceptions:
// T:System.ArgumentNullException:
// destination is null.
//
// T:System.ObjectDisposedException:
// Either the current stream or the destination stream is disposed.
//
// T:System.NotSupportedException:
// The current stream does not support reading, or the destination stream does not
// support writing.
[ComVisible(false)]
Task CopyToAsync(IStream destination);
//
// Summary:
// Asynchronously reads the bytes from the current stream and writes them to another
// stream, using a specified buffer size.
//
// Parameters:
// destination:
// The stream to which the contents of the current stream will be copied.
//
// bufferSize:
// The size, in bytes, of the buffer. This value must be greater than zero. The
// default size is 81920.
//
// Returns:
// A task that represents the asynchronous copy operation.
//
// Exceptions:
// T:System.ArgumentNullException:
// destination is null.
//
// T:System.ArgumentOutOfRangeException:
// buffersize is negative or zero.
//
// T:System.ObjectDisposedException:
// Either the current stream or the destination stream is disposed.
//
// T:System.NotSupportedException:
// The current stream does not support reading, or the destination stream does not
// support writing.
[ComVisible(false)]
Task CopyToAsync(IStream destination, int bufferSize);
//
// Summary:
// Asynchronously reads the bytes from the current stream and writes them to another
// stream, using a specified buffer size and cancellation token.
//
// Parameters:
// destination:
// The stream to which the contents of the current stream will be copied.
//
// bufferSize:
// The size, in bytes, of the buffer. This value must be greater than zero. The
// default size is 81920.
//
// cancellationToken:
// The token to monitor for cancellation requests. The default value is System.Threading.CancellationToken.None.
//
// Returns:
// A task that represents the asynchronous copy operation.
//
// Exceptions:
// T:System.ArgumentNullException:
// destination is null.
//
// T:System.ArgumentOutOfRangeException:
// buffersize is negative or zero.
//
// T:System.ObjectDisposedException:
// Either the current stream or the destination stream is disposed.
//
// T:System.NotSupportedException:
// The current stream does not support reading, or the destination stream does not
// support writing.
[ComVisible(false)]
Task CopyToAsync(IStream destination, int bufferSize, CancellationToken cancellationToken);
} }
} }

Просмотреть файл

@ -631,5 +631,30 @@ namespace SystemWrapper.IO
{ {
await FileStreamInstance.WriteAsync(buffer, offset, count, cancellationToken); await FileStreamInstance.WriteAsync(buffer, offset, count, cancellationToken);
} }
public void CopyTo(IStream destination)
{
StreamInstance.CopyTo(destination.StreamInstance);
}
public void CopyTo(IStream destination, int bufferSize)
{
StreamInstance.CopyTo(destination.StreamInstance, bufferSize);
}
public async Task CopyToAsync(IStream destination)
{
await StreamInstance.CopyToAsync(destination.StreamInstance);
}
public async Task CopyToAsync(IStream destination, int bufferSize)
{
await StreamInstance.CopyToAsync(destination.StreamInstance, bufferSize);
}
public async Task CopyToAsync(IStream destination, int bufferSize, CancellationToken cancellationToken)
{
await StreamInstance.CopyToAsync(destination.StreamInstance, bufferSize, cancellationToken);
}
} }
} }

Просмотреть файл

@ -434,5 +434,30 @@ namespace SystemWrapper.IO
{ {
await MemoryStreamInstance.WriteAsync(buffer, offset, count, cancellationToken); await MemoryStreamInstance.WriteAsync(buffer, offset, count, cancellationToken);
} }
public void CopyTo(IStream destination)
{
StreamInstance.CopyTo(destination.StreamInstance);
}
public void CopyTo(IStream destination, int bufferSize)
{
StreamInstance.CopyTo(destination.StreamInstance, bufferSize);
}
public async Task CopyToAsync(IStream destination)
{
await StreamInstance.CopyToAsync(destination.StreamInstance);
}
public async Task CopyToAsync(IStream destination, int bufferSize)
{
await StreamInstance.CopyToAsync(destination.StreamInstance, bufferSize);
}
public async Task CopyToAsync(IStream destination, int bufferSize, CancellationToken cancellationToken)
{
await StreamInstance.CopyToAsync(destination.StreamInstance, bufferSize, cancellationToken);
}
} }
} }

Просмотреть файл

@ -385,6 +385,31 @@
this.StreamInstance.WriteByte(value); this.StreamInstance.WriteByte(value);
} }
public void CopyTo(IStream destination)
{
StreamInstance.CopyTo(destination.StreamInstance);
}
public void CopyTo(IStream destination, int bufferSize)
{
StreamInstance.CopyTo(destination.StreamInstance, bufferSize);
}
public async Task CopyToAsync(IStream destination)
{
await StreamInstance.CopyToAsync(destination.StreamInstance);
}
public async Task CopyToAsync(IStream destination, int bufferSize)
{
await StreamInstance.CopyToAsync(destination.StreamInstance, bufferSize);
}
public async Task CopyToAsync(IStream destination, int bufferSize, CancellationToken cancellationToken)
{
await StreamInstance.CopyToAsync(destination.StreamInstance, bufferSize, cancellationToken);
}
#endregion #endregion
} }
} }