IContentWriteAsync Method

Task<bool> WriteAsync(
	Stream content,
	string contentType,
	long startIndex,
	long totalFileSize
)

Function WriteAsync ( 
	content As Stream,
	contentType As String,
	startIndex As Long,
	totalFileSize As Long
) As Task(Of Boolean)

Task<bool>^ WriteAsync(
	Stream^ content, 
	String^ contentType, 
	long long startIndex, 
	long long totalFileSize
)

abstract WriteAsync : 
        content : Stream * 
        contentType : string * 
        startIndex : int64 * 
        totalFileSize : int64 -> Task<bool> 

<configuration>
   <system.web>
      ...
      <httpRuntime maxRequestLength="2097151" /> //2Gb
      ...
   </system.web>
</configuration>

<configuration>
    <system.web>
       ...
       <compilation tempDirectory="temporary files directory" />
       ...
    </system.web>
</configuration>

public virtual async Task<bool> WriteAsync(Stream content, string contentType, long startIndex, long totalFileSize)
{
    await RequireHasTokenAsync();
    //Set timeout to maximum value to be able to upload large files.
    HttpContext.Current.Server.ScriptTimeout = int.MaxValue;
    await WriteInternalAsync(content, contentType, startIndex, totalFileSize);
    await context.socketService.NotifyUpdatedAsync(Path, GetWebSocketID());
    return true;
}

public async Task<bool> WriteInternalAsync(Stream content, string contentType, long startIndex, long totalFileSize)
{
    if (startIndex == 0 && fileInfo.Length > 0)
    {
        using (FileStream filestream = fileInfo.Open(FileMode.Truncate)) { }
    }
    await fileInfo.SetExtendedAttributeAsync("TotalContentLength", (object)totalFileSize);
    await fileInfo.SetExtendedAttributeAsync("SerialNumber", ++this.serialNumber);

    using (FileStream fileStream = fileInfo.Open(FileMode.OpenOrCreate, FileAccess.Write, FileShare.Read))
    {
        if (fileStream.Length < startIndex)
        {
            throw new DavException("Previous piece of file was not uploaded.", DavStatus.PRECONDITION_FAILED);
        }

        if (!content.CanRead)
        {
            return true;
        }

        fileStream.Seek(startIndex, SeekOrigin.Begin);
        byte[] buffer = new byte[bufSize];

        int lastBytesRead;
        try
        {
            lastBytesRead = await content.ReadAsync(buffer, 0, bufSize);
            while (lastBytesRead > 0)
            {
                await fileStream.WriteAsync(buffer, 0, lastBytesRead);
                lastBytesRead = await content.ReadAsync(buffer, 0, bufSize);
            }
        }
        catch (HttpException)
        {
            // The remote host closed the connection (for example Cancel or Pause pressed).
        }
    }
    return true;
}

Public Overridable Async Function WriteAsync(content As Stream, contentType As String, startIndex As Long, totalFileSize As Long) As Task(Of Boolean) Implements IContent.WriteAsync
    Await RequireHasTokenAsync()
    'Set timeout to maximum value to be able to upload large files.
    HttpContext.Current.Server.ScriptTimeout = Integer.MaxValue
    Await WriteInternalAsync(content, contentType, startIndex, totalFileSize)
    Await context.socketService.NotifyUpdatedAsync(Path, GetWebSocketID())
    Return True
End Function

Public Async Function WriteInternalAsync(content As Stream, contentType As String, startIndex As Long, totalFileSize As Long) As Task(Of Boolean)
    If startIndex = 0 AndAlso fileInfo.Length > 0 Then
        Using filestream As FileStream = fileInfo.Open(FileMode.Truncate)
             End Using
    End If

    Await fileInfo.SetExtendedAttributeAsync("TotalContentLength", CObj(totalFileSize))
    Await fileInfo.SetExtendedAttributeAsync("SerialNumber", System.Threading.Interlocked.Increment(Me.serialNumber))
    Using fileStream As FileStream = fileInfo.Open(FileMode.OpenOrCreate, FileAccess.Write, FileShare.Read)
        If fileStream.Length < startIndex Then
            Throw New DavException("Previous piece of file was not uploaded.", DavStatus.PRECONDITION_FAILED)
        End If

        If Not content.CanRead Then
            Return True
        End If

        fileStream.Seek(startIndex, SeekOrigin.Begin)
        Dim buffer As Byte() = New Byte(1048575) {}
        Dim lastBytesRead As Integer
        Try
            lastBytesRead = Await content.ReadAsync(buffer, 0, bufSize)
            While lastBytesRead > 0
                Await fileStream.WriteAsync(buffer, 0, lastBytesRead)
                lastBytesRead = Await content.ReadAsync(buffer, 0, bufSize)
            End While
        Catch __unusedHttpException1__ As HttpException
            ' The remote host closed the connection (for example Cancel or Pause pressed).
             End Try
    End Using

    Return True
End Function

No code example is currently available or this language may not be supported.

No code example is currently available or this language may not be supported.

public virtual async Task<bool> WriteAsync(Stream content, string contentType, long startIndex, long totalFileSize)
{
    await RequireHasTokenAsync();
    await WriteInternalAsync(content, contentType, startIndex, totalFileSize);
    await context.socketService.NotifyUpdatedAsync(Path, GetWebSocketID());
    return true;
}

public async Task<bool> WriteInternalAsync(Stream content, string contentType, long startIndex, long totalFileSize)
{
    if (startIndex == 0 && fileInfo.Length > 0)
    {
        await using (FileStream filestream = fileInfo.Open(FileMode.Truncate)) { }
    }
    await fileInfo.SetExtendedAttributeAsync("TotalContentLength", (object)totalFileSize);
    await fileInfo.SetExtendedAttributeAsync("SerialNumber", ++this.serialNumber);

    await using (FileStream fileStream = fileInfo.Open(FileMode.OpenOrCreate, FileAccess.Write, FileShare.Read))
    {
        if (fileStream.Length < startIndex)
        {
            throw new DavException("Previous piece of file was not uploaded.", DavStatus.PRECONDITION_FAILED);
        }

        if (!content.CanRead)
        {
            return true;
        }

        fileStream.Seek(startIndex, SeekOrigin.Begin);
        byte[] buffer = new byte[bufSize];

        int lastBytesRead;
        try
        {
            lastBytesRead = await content.ReadAsync(buffer, 0, bufSize);
            while (lastBytesRead > 0)
            {
                await fileStream.WriteAsync(buffer, 0, lastBytesRead);
                lastBytesRead = await content.ReadAsync(buffer, 0, bufSize);
            }
        }
        catch (IOException)
        {
            // Message = "Error -4077 ECONNRESET connection reset by peer"
            // The remote host closed the connection (for example Cancel or Pause pressed).
        }
    }
    return true;
}