1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
|
// <copyright>
// Copyright (c) Microsoft Corporation. All rights reserved.
// </copyright>
namespace System.ServiceModel.Channels
{
using System;
using System.IO;
using System.Net;
using System.Net.Http;
using System.Runtime;
using System.Threading.Tasks;
class OpaqueContent : HttpContent
{
MessageEncoder messageEncoder;
Message message;
string mtomBoundary;
public OpaqueContent(MessageEncoder encoder, Message message, string mtomBoundary)
{
Fx.Assert(encoder != null, "encoder should not be null.");
Fx.Assert(message != null, "message should not be null.");
this.messageEncoder = encoder;
this.message = message;
this.mtomBoundary = mtomBoundary;
}
public bool IsEmpty
{
get
{
return this.message.IsEmpty;
}
}
public void WriteToStream(Stream stream)
{
Fx.Assert(stream != null, "stream should not be null.");
MtomMessageEncoder mtomMessageEncoder = this.messageEncoder as MtomMessageEncoder;
if (mtomMessageEncoder == null)
{
this.messageEncoder.WriteMessage(this.message, stream);
}
else
{
mtomMessageEncoder.WriteMessage(this.message, stream, this.mtomBoundary);
}
}
public IAsyncResult BeginWriteToStream(Stream stream, AsyncCallback callback, object state)
{
Fx.Assert(stream != null, "stream should not be null.");
MtomMessageEncoder mtomMessageEncoder = this.messageEncoder as MtomMessageEncoder;
if (mtomMessageEncoder == null)
{
return this.messageEncoder.BeginWriteMessage(this.message, stream, callback, state);
}
else
{
return mtomMessageEncoder.BeginWriteMessage(this.message, stream, this.mtomBoundary, callback, state);
}
}
public void EndWriteToStream(IAsyncResult result)
{
this.messageEncoder.EndWriteMessage(result);
}
protected override Task SerializeToStreamAsync(Stream stream, TransportContext context)
{
throw DiagnosticUtility.ExceptionUtility.ThrowHelperError(new NotSupportedException(
SR.GetString(SR.WebSocketOpaqueStreamContentNotSupportError)));
}
protected override bool TryComputeLength(out long length)
{
length = 0;
return false;
}
}
}
|
