2 writes to MessageEncoder
System.ServiceModel (2)
System\ServiceModel\Channels\FramingChannels.cs (1)
196
this.
MessageEncoder
= settings.MessageEncoderFactory.CreateSessionEncoder();
System\ServiceModel\Channels\SessionConnectionReader.cs (1)
515
this.
MessageEncoder
= channelListener.MessageEncoderFactory.CreateSessionEncoder();
17 references to MessageEncoder
System.ServiceModel (17)
System\ServiceModel\Channels\FramingChannels.cs (7)
119
ArraySegment<byte> messageData =
MessageEncoder
.WriteMessage(message,
205
EncodedContentType encodedContentType = EncodedContentType.Create(this.
MessageEncoder
.ContentType);
270
ConnectionUpgradeHelper.DecodeFramingFault(this.decoder, connection, Via,
MessageEncoder
.ContentType, ref timeoutHelper);
289
MessageEncoder
.ContentType, ref timeoutHelper);
356
base.SetMessageSource(new ClientDuplexConnectionReader(this, connection, decoder, this.settings,
MessageEncoder
));
535
channel.
MessageEncoder
.ContentType, this.identityToImpersonate, timeoutHelper, onUpgrade, this);
619
connection, channel.Via, channel.
MessageEncoder
.ContentType, ref timeoutHelper,
System\ServiceModel\Channels\SessionConnectionReader.cs (4)
517
if (!this.
MessageEncoder
.IsContentTypeSupported(decoder.ContentType))
521
SR.ContentTypeMismatch, decoder.ContentType, this.
MessageEncoder
.ContentType)));
524
ICompressedMessageEncoder compressedMessageEncoder = this.
MessageEncoder
as ICompressedMessageEncoder;
997
this.messageEncoder = channel.
MessageEncoder
;
System\ServiceModel\Channels\WebSocketTransportDuplexSessionChannel.cs (6)
268
IAsyncResult result = this.
MessageEncoder
.BeginWriteMessage(message, new TimeoutStream(webSocketStream, ref helper), streamedWriteCallback, this);
275
this.
MessageEncoder
.EndWriteMessage(result);
325
this.
MessageEncoder
.WriteMessage(message, timeoutStream);
373
return
MessageEncoder
.WriteMessage(message, int.MaxValue, this.BufferManager, 0);
469
thisPtr.
MessageEncoder
.EndWriteMessage(ar);
536
this.encoder = webSocketTransportDuplexSessionChannel.
MessageEncoder
;