Mercurial > pub > ImplabNet

annotate Implab/Messaging/IProducer.cs @ 264:3a6e18c432be v3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Added XmlToJson xsl transformation. Added JsonXmlReader.CreateJsonXmlReader(...) methods Added SerializationHelpers.SerializeJson/DeserializeJson methods
author cin
date Mon, 16 Apr 2018 18:43:49 +0300
parents 7c7e9ad6fe4a
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
250
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
1 using System.Collections.Generic;
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
2 using System.Threading;
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
3 using System.Threading.Tasks;
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
4
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
5 namespace Implab.Messaging {
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
6 public interface IProducer<T> {
251
7c7e9ad6fe4a Prerelease version of RunnableComponent
cin
parents: 250
diff changeset
7 void PostMessage(T message, CancellationToken ct);
7c7e9ad6fe4a Prerelease version of RunnableComponent
cin
parents: 250
diff changeset
8
250
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
9 Task PostMessageAsync(T message, CancellationToken ct);
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
10
251
7c7e9ad6fe4a Prerelease version of RunnableComponent
cin
parents: 250
diff changeset
11 void PostMessages(IEnumerable<T> messages, CancellationToken ct);
7c7e9ad6fe4a Prerelease version of RunnableComponent
cin
parents: 250
diff changeset
12
250
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
13 Task PostMessagesAsync(IEnumerable<T> messages, CancellationToken ct);
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
14 }
9f63dade3a40 Working on runnable component
cin
parents:
diff changeset
15 }