diff --git a/src/Orleans/Orleans.csproj b/src/Orleans/Orleans.csproj index 2182c98e5b0..d751ccb08b1 100644 --- a/src/Orleans/Orleans.csproj +++ b/src/Orleans/Orleans.csproj @@ -278,7 +278,7 @@ - + @@ -291,7 +291,7 @@ - + diff --git a/src/Orleans/Streams/SimpleMessageStream/SimpleMessageStreamProvider.cs b/src/Orleans/Streams/SimpleMessageStream/SimpleMessageStreamProvider.cs index dfb72daab86..c611d247222 100644 --- a/src/Orleans/Streams/SimpleMessageStream/SimpleMessageStreamProvider.cs +++ b/src/Orleans/Streams/SimpleMessageStream/SimpleMessageStreamProvider.cs @@ -63,9 +63,6 @@ public Task Start() public IAsyncStream GetStream(Guid id, string streamNamespace) { - if (id == null) - throw new ArgumentNullException("id"); - var streamId = StreamId.GetStreamId(id, Name, streamNamespace); return providerRuntime.GetStreamDirectory().GetOrAddStream( streamId, diff --git a/src/OrleansRuntime/Streams/PersistentStream/PersistentStreamProvider.cs b/src/OrleansRuntime/Streams/PersistentStream/PersistentStreamProvider.cs index 70e905bbcee..64861af28d2 100644 --- a/src/OrleansRuntime/Streams/PersistentStream/PersistentStreamProvider.cs +++ b/src/OrleansRuntime/Streams/PersistentStream/PersistentStreamProvider.cs @@ -119,8 +119,6 @@ public async Task Start() public IAsyncStream GetStream(Guid id, string streamNamespace) { - if (id == null) throw new ArgumentNullException("id"); - var streamId = StreamId.GetStreamId(id, Name, streamNamespace); return providerRuntime.GetStreamDirectory().GetOrAddStream( streamId, () => new StreamImpl(streamId, this, IsRewindable));