topic.subscribe()

Subscribe a handler to a topic and receive new events for processing.

using Nitric.Sdk;

var updates = Nitric.Topic("updates");

updates.Subscribe(context => {
  Console.WriteLine(context.Req.Payload);

  return context;
});

Nitric.Run();

Parameters

middleware required Func<EventContext, EventContext> or Middleware<EventContext>[]

The middleware (code) to be triggered by the topic.

Examples

Subscribe to a topic

using Nitric.Sdk;

var updates = Nitric.Topic("updates");

updates.Subscribe(context => {
  Console.WriteLine(context.Req.Payload);

  return context;
});

Nitric.Run();

Subscibe to a topic with chained middleware

using Nitric.Sdk;

var updates = Nitric.Topic("updates");

updates.Subscribe((context, next) =>
  {
    // Validate request

    return next(context);
  }, (context, next) => {
    Console.WriteLine(context.Req.Payload);

    return next(context);
  }
);

Nitric.Run();

Notes

• A function may only subscribe to a topic once, if multiple subscribers are required, create them in different functions.
• A function may subscribe to OR publish to a topic but not both