pawanrao

class TestGrain : Grain, ITestGrain {
	private const string StreamProvider = "test_provider"
	private const string StreamNamespace = "test_namespace"
	
	public override async Task OnActivateAsync() {
        var streamProvider = this.GetStreamProvider(StreamProvider);
        var stream = streamProvider.GetStream<Foo>(this.GetPrimaryKey(), StreamNamespace);
        var subscriptionHandles = await stream.GetAllSubscriptionHandles();
        if (subscriptionHandles != null && subscriptionHandles.Any()) {
            foreach (var handle in subscriptionHandles) {