Mercurial > pub > ImplabNet

annotate Implab/Messaging/IProducer.cs @ 251:7c7e9ad6fe4a v3

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Prerelease version of RunnableComponent Added draft messaging interfaces Added more more helpers to Xml/SerializationHelpers
author cin
date Sun, 11 Feb 2018 00:49:51 +0300
parents 9f63dade3a40
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 }