Permalink
Browse files

Merge branch 'dev' of github.com:EventStore/EventStore

  • Loading branch information...
2 parents 9d3c4b3 + b37c0d4 commit 4d05ebe21a02b4b68affeb96693f25975ca5763f @gregoryyoung gregoryyoung committed Mar 1, 2014
Showing with 8,668 additions and 1,093 deletions.
  1. +1 −1 src/EventStore/EventStore.ClientAPI/ClientOperations/SubscriptionOperation.cs
  2. +1 −1 src/EventStore/EventStore.ClientAPI/Common/SystemNames.cs
  3. +1 −1 src/EventStore/EventStore.ClientAPI/EventStore.ClientAPI.csproj
  4. +5 −0 src/EventStore/EventStore.ClientAPI/ProjectionsClient.cs
  5. +24 −1 src/EventStore/EventStore.ClientAPI/ProjectionsManager.cs
  6. +15 −0 src/EventStore/EventStore.ClientAPI/RecordedEvent.cs
  7. +1 −1 src/EventStore/EventStore.ClientAPI/ResolvedEvent.cs
  8. +1 −1 src/EventStore/EventStore.Common/EventStore.Common.csproj
  9. +1 −1 src/EventStore/EventStore.Core.Tests/ClientAPI/Helpers/TestEvent.cs
  10. +62 −0 src/EventStore/EventStore.Core.Tests/ClientAPI/SpecificationWithMiniNode.cs
  11. +2 −18 src/EventStore/EventStore.Core.Tests/ClientAPI/read_all_events_backward_should.cs
  12. +2 −18 src/EventStore/EventStore.Core.Tests/ClientAPI/read_all_events_forward_should.cs
  13. +82 −0 ...tStore/EventStore.Core.Tests/ClientAPI/read_all_events_forward_with_hard_deleted_stream_should.cs
  14. +84 −0 ...tStore/EventStore.Core.Tests/ClientAPI/read_all_events_forward_with_soft_deleted_stream_should.cs
  15. +2 −20 src/EventStore/EventStore.Core.Tests/ClientAPI/read_event_should.cs
  16. +81 −0 src/EventStore/EventStore.Core.Tests/ClientAPI/read_stream_events_with_unresolved_linkto.cs
  17. +80 −98 src/EventStore/EventStore.Core.Tests/ClientAPI/when_having_truncatebefore_set_for_stream.cs
  18. +6 −1 src/EventStore/EventStore.Core.Tests/EventStore.Core.Tests.csproj
  19. +24 −5 src/EventStore/EventStore.Core.Tests/Helpers/ManualQueue.cs
  20. +69 −22 src/EventStore/EventStore.Core.Tests/Helpers/TestFixtureWithExistingEvents.cs
  21. +3 −2 src/EventStore/EventStore.Core.Tests/Helpers/TestFixtureWithReadWriteDispatchers.cs
  22. +39 −0 src/EventStore/EventStore.Core.Tests/Http/Streams/basic.cs
  23. +124 −0 src/EventStore/EventStore.Core.Tests/Http/Streams/idempotency.cs
  24. +1 −1 src/EventStore/EventStore.Core.Tests/Services/UserManagementService/user_management_service.cs
  25. +107 −1 src/EventStore/EventStore.Core/Bus/QueueStatsCollector.cs
  26. +6 −0 src/EventStore/EventStore.Core/Bus/QueuedHandlerAutoReset.cs
  27. +6 −0 src/EventStore/EventStore.Core/Bus/QueuedHandlerMRES.cs
  28. +6 −0 src/EventStore/EventStore.Core/Bus/QueuedHandlerPulse.cs
  29. +6 −0 src/EventStore/EventStore.Core/Bus/QueuedHandlerSleep.cs
  30. +6 −0 src/EventStore/EventStore.Core/Bus/QueuedHandlerThreadPool.cs
  31. +15 −3 src/EventStore/EventStore.Core/Data/ResolvedEvent.cs
  32. +77 −67 src/EventStore/EventStore.Core/Data/StreamMetadata.cs
  33. +2 −1 src/EventStore/EventStore.Core/EventStore.Core.csproj
  34. +2 −3 src/EventStore/EventStore.Core/Index/Hashes/Murmur2Unsafe.cs
  35. +3 −4 src/EventStore/EventStore.Core/Index/Hashes/Murmur3AUnsafe.cs
  36. +3 −4 src/EventStore/EventStore.Core/Index/Hashes/XXHashUnsafe.cs
  37. +9 −3 src/EventStore/EventStore.Core/Services/Storage/StorageReaderWorker.cs
  38. +10 −5 src/EventStore/EventStore.Core/Services/SubscriptionsService.cs
  39. +8 −2 src/EventStore/EventStore.Core/Services/Transport/Http/Convert.cs
  40. +3 −0 src/EventStore/EventStore.Core/SingleVNode.cs
  41. +2 −1 src/EventStore/EventStore.Core/TransactionLog/Checkpoint/FileCheckpoint.cs
  42. +113 −0 src/EventStore/EventStore.Projections.Core.Tests/ClientAPI/event_by_type_index.cs
  43. +82 −0 ...ore.Projections.Core.Tests/ClientAPI/event_by_type_index/when_reverting_after_index_catches_up.cs
  44. +260 −0 ...e/EventStore.Projections.Core.Tests/ClientAPI/specification_with_standard_projections_runnning.cs
  45. +72 −0 ...when_handling_created/with_from_all_any_foreach_projection/when_running_and_events_are_indexed.cs
  46. +71 −0 .../when_handling_created/with_from_all_any_foreach_projection/when_running_and_events_are_posted.cs
  47. +71 −0 ...API/when_handling_created/with_from_all_foreach_projection/when_running_and_events_are_indexed.cs
  48. +73 −0 ...hen_handling_created/with_from_category_foreach_projection/when_running_and_events_are_indexed.cs
  49. +77 −0 ...rom_all_any_foreach_projection/recovery/when_running_and_a_stream_gets_deleted_before_recovery.cs
  50. +77 −0 ...dling_deleted/with_from_all_any_foreach_projection/recovery/when_running_and_events_are_posted.cs
  51. +72 −0 ...when_handling_deleted/with_from_all_any_foreach_projection/when_running_and_events_are_indexed.cs
  52. +72 −0 .../when_handling_deleted/with_from_all_any_foreach_projection/when_running_and_events_are_posted.cs
  53. +75 −0 ...any_foreach_projection/when_running_and_events_are_posted_but_a_stream_and_tombstone_postponed.cs
  54. +71 −0 ..._deleted/with_from_all_any_foreach_projection/when_running_and_events_are_posted_but_tombstone.cs
  55. +75 −0 ...ed/with_from_all_any_foreach_projection/when_running_and_events_are_posted_including_tombstone.cs
  56. +78 −0 ..._from_all_any_foreach_projection/when_running_and_then_other_events_tombstone_ant_other_events.cs
  57. +84 −0 ...handling_deleted/with_from_all_foreach_projection/recovery/when_running_and_events_are_indexed.cs
  58. +84 −0 .../with_from_all_foreach_projection/recovery/when_running_and_events_get_indexed_before_recovery.cs
  59. +86 −0 ...API/when_handling_deleted/with_from_all_foreach_projection/when_running_and_events_are_indexed.cs
  60. +87 −0 ...ith_from_all_foreach_projection/when_running_and_events_are_indexed_but_a_stream_and_tombstone.cs
  61. +88 −0 ..._from_all_foreach_projection/when_running_and_events_are_indexed_but_more_events_and_tombstone.cs
  62. +87 −0 ...ing_deleted/with_from_all_foreach_projection/when_running_and_events_are_indexed_but_tombstone.cs
  63. +73 −0 .../ClientAPI/when_handling_deleted/with_from_all_foreach_projection/when_running_and_no_indexing.cs
  64. +79 −0 ...andling_deleted/with_from_all_foreach_projection/when_running_and_no_indexing_and_other_events.cs
  65. +80 −0 ...ing_deleted/with_from_category_foreach_projection/recovery/when_running_and_events_are_indexed.cs
  66. +80 −0 ..._from_category_foreach_projection/recovery/when_running_and_events_get_indexed_before_recovery.cs
  67. +74 −0 ...hen_handling_deleted/with_from_category_foreach_projection/when_running_and_events_are_indexed.cs
  68. +83 −0 ...ry_foreach_projection/when_running_and_events_are_indexed_but_a_stream_and_tombstone_postponed.cs
  69. +74 −0 ...eleted/with_from_category_foreach_projection/when_running_and_events_are_indexed_but_tombstone.cs
  70. +76 −0 .../with_from_category_foreach_projection/when_running_and_events_are_indexed_including_tombstone.cs
  71. +81 −0 ...from_category_foreach_projection/when_running_and_then_other_events_tombstone_ant_other_events.cs
  72. +121 −0 src/EventStore/EventStore.Projections.Core.Tests/ClientAPI/with_standard_projections_running.cs
  73. +89 −44 src/EventStore/EventStore.Projections.Core.Tests/EventStore.Projections.Core.Tests.csproj
  74. +116 −0 ...entStore.Projections.Core.Tests/Integration/scenarios/when_deleting_already_categorized_stream.cs
  75. +8 −1 src/EventStore/EventStore.Projections.Core.Tests/Integration/specification_with_a_v8_query_posted.cs
  76. +1 −1 ...entStore.Projections.Core.Tests/Integration/system_projections/when_running_system_projections.cs
  77. +1 −0 src/EventStore/EventStore.Projections.Core.Tests/Services/TestFixtureWithProjectionCoreService.cs
  78. +45 −0 src/EventStore/EventStore.Projections.Core.Tests/Services/awake_reader_service/when_creating.cs
  79. +86 −0 ...e/EventStore.Projections.Core.Tests/Services/awake_reader_service/when_handling_comitted_event.cs
  80. +186 −0 ...tions.Core.Tests/Services/awake_reader_service/when_handling_committed_event_after_unsybscribe.cs
  81. +170 −0 ...ctions.Core.Tests/Services/awake_reader_service/when_handling_committed_event_with_subscribers.cs
  82. +93 −0 .../EventStore.Projections.Core.Tests/Services/awake_reader_service/when_handling_subscribe_awake.cs
  83. +153 −0 ...vices/awake_reader_service/when_subscribing_before_last_position_with_already_committed_events.cs
  84. +9 −0 ...re.Projections.Core.Tests/Services/checkpoint_tag/checkpoint_tag_by_event_type_index_positions.cs
  85. +13 −0 src/EventStore/EventStore.Projections.Core.Tests/Services/core_projection/FakeProjectionHandler.cs
  86. +10 −0 ...Store/EventStore.Projections.Core.Tests/Services/core_projection/TestFixtureWithExistingEvents.cs
  87. +1 −0 ...EventStore.Projections.Core.Tests/Services/core_projection/TestFixtureWithReadWriteDispatchers.cs
  88. +1 −0 ...sts/Services/core_projection/checkpoint_manager/TestFixtureWithCoreProjectionCheckpointManager.cs
  89. +2 −1 ...Core.Tests/Services/core_projection/multi_phase/specification_with_multi_phase_core_projection.cs
  90. +79 −0 ...tions.Core.Tests/Services/core_projection/when_creating_a_new_partitiion_the_projection_should.cs
  91. +1 −0 ...entStore/EventStore.Projections.Core.Tests/Services/core_projection/when_starting_a_projection.cs
  92. +2 −1 ...ts/Services/{core_projection → }/emitted_stream/a_checkpoint_requested_on_a_non_started_stream.cs
  93. +2 −1 ...ed_stream/another_epoch/when_handling_an_emit_with_expected_tag_the_started_in_recovery_stream.cs
  94. +3 −1 ...d_stream/another_epoch/when_handling_emits_with_previously_written_events_at_the_same_position.cs
  95. +3 −2 ...ed_stream/another_epoch/when_handling_emits_with_previously_written_events_in_different_epochs.cs
  96. +2 −1 ...ream/another_projection/when_handling_an_emit_with_expected_tag_the_started_in_recovery_stream.cs
  97. +2 −1 ....Projections.Core.Tests/Services/{core_projection → }/emitted_stream/when_checkpoint_requested.cs
  98. +2 −1 ...Core.Tests/Services/{core_projection → }/emitted_stream/when_checkpoint_requested_but_disabled.cs
  99. +3 −2 ...core_projection → }/emitted_stream/when_checkpoint_requested_with_all_writes_already_completed.cs
  100. +2 −2 ...sts/Services/{core_projection → }/emitted_stream/when_checkpoint_requested_with_pending_writes.cs
  101. +2 −1 ...ctions.Core.Tests/Services/{core_projection → }/emitted_stream/when_creating_an_emitted_stream.cs
  102. +2 −1 ...ests/Services/{core_projection → }/emitted_stream/when_handling_an_emit_the_not_started_stream.cs
  103. +2 −1 ...vices/{core_projection → }/emitted_stream/when_handling_an_emit_the_started_in_recovery_stream.cs
  104. +2 −1 ...s/Services/{core_projection → }/emitted_stream/when_handling_an_emit_to_the_nonexisting_stream.cs
  105. +3 −1 ...es/{core_projection → }/emitted_stream/when_handling_an_emit_with_caused_by_and_correlation_id.cs
  106. +2 −1 ...sts/Services/{core_projection → }/emitted_stream/when_handling_an_emit_with_committed_callback.cs
  107. +2 −1 ...tion → }/emitted_stream/when_handling_an_emit_with_expected_tag_the_started_in_recovery_stream.cs
  108. +3 −1 ...e.Tests/Services/{core_projection → }/emitted_stream/when_handling_an_emit_with_extra_metadata.cs
  109. +2 −2 ....Tests/Services/{core_projection → }/emitted_stream/when_handling_an_emit_with_not_ready_event.cs
  110. +2 −1 ....Tests/Services/{core_projection → }/emitted_stream/when_handling_an_emit_with_stream_metadata.cs
  111. +2 −2 ...ts/Services/{core_projection → }/emitted_stream/when_handling_an_emit_with_write_as_configured.cs
  112. +2 −1 ...s.Core.Tests/Services/{core_projection → }/emitted_stream/when_handling_emits_in_invalid_order.cs
  113. +29 −2 ...ervices/{core_projection → }/emitted_stream/when_handling_emits_with_previously_written_events.cs
  114. +3 −2 ...ion → }/emitted_stream/when_handling_emits_with_previously_written_events_at_the_same_position.cs
  115. +2 −1 ...Projections.Core.Tests/Services/{core_projection → }/emitted_stream/when_the_stream_is_started.cs
  116. +2 −1 ...ces/{core_projection → }/emitted_stream/when_the_stream_is_started_with_already_emitted_events.cs
  117. +9 −0 ...tStore/EventStore.Projections.Core.Tests/Services/event_filter/include_everything_event_filter.cs
  118. +26 −22 ...re.Tests/Services/event_filter/include_everything_handling_deleted_notifications_event_filter.cs}
  119. +2 −1 ...tore/EventStore.Projections.Core.Tests/Services/event_reader/TestFixtureWithEventReaderService.cs
  120. +2 −2 ...ections.Core.Tests/Services/event_reader/all_streams_catalog_event_reader/when_reading_catalog.cs
  121. +3 −3 ...tions.Core.Tests/Services/event_reader/event_by_type_index_reader/catching_up/index_checkpoint.cs
  122. +13 −0 ...Store.Projections.Core.Tests/Services/event_reader/heading_event_reader/FakeReaderSubscription.cs
  123. +2 −2 ...ore.Tests/Services/event_reader/multi_stream_reader/when_handling_read_completed_and_no_stream.cs
  124. +2 −11 ...ervices/event_reader/multi_stream_reader/when_handling_read_completed_for_all_streams_and_eofs.cs
  125. +18 −6 ...e.Projections.Core.Tests/Services/event_reader/stream_reader/when_creating_stream_event_reader.cs
  126. +2 −1 ...tore.Projections.Core.Tests/Services/event_reader/stream_reader/when_handling_eof_and_idle_eof.cs
  127. +4 −12 .../EventStore.Projections.Core.Tests/Services/event_reader/stream_reader/when_handling_no_stream.cs
  128. +9 −15 ...rojections.Core.Tests/Services/event_reader/stream_reader/when_handling_read_completed_and_eof.cs
  129. +6 −5 ...ore.Tests/Services/event_reader/stream_reader/when_handling_read_completed_stream_event_reader.cs
  130. +6 −5 ...ore.Tests/Services/event_reader/stream_reader/when_handling_read_completed_then_pause_then_eof.cs
  131. +1 −1 ...ore.Projections.Core.Tests/Services/event_reader/stream_reader/when_onetime_reader_handles_eof.cs
  132. +2 −1 ...Projections.Core.Tests/Services/event_reader/stream_reader/when_paused_then_handling_no_stream.cs
  133. +2 −1 ...e.Projections.Core.Tests/Services/event_reader/stream_reader/when_resuming_stream_event_reader.cs
  134. +2 −1 ...tions.Core.Tests/Services/event_reader/stream_reader/when_stream_event_reader_has_been_created.cs
  135. +9 −6 ...ctions.Core.Tests/Services/event_reader/transaction_file_reader/when_handling_eof_and_idle_eof.cs
  136. +101 −0 ...ons.Core.Tests/Services/event_reader/transaction_file_reader/when_handling_stream_hard_deleted.cs
  137. +103 −0 ...ons.Core.Tests/Services/event_reader/transaction_file_reader/when_handling_stream_soft_deleted.cs
  138. +2 −0 ....Projections.Core.Tests/Services/projection_subscription/TestFixtureWithProjectionSubscription.cs
  139. +12 −0 ...ventStore/EventStore.Projections.Core.Tests/Services/projections_manager/FakeBiStateProjection.cs
  140. +12 −0 ...ore/EventStore.Projections.Core.Tests/Services/projections_manager/FakeForeachStreamProjection.cs
  141. +10 −0 ...EventStore.Projections.Core.Tests/Services/projections_manager/FakeFromCatalogStreamProjection.cs
  142. +12 −0 src/EventStore/EventStore.Projections.Core.Tests/Services/projections_manager/FakeProjection.cs
  143. +6 −1 ...ons.Core.Tests/Services/projections_manager/TestFixtureWithProjectionCoreAndManagementServices.cs
  144. +6 −2 ...ntStore.Projections.Core.Tests/Services/projections_manager/continuous/a_new_posted_projection.cs
  145. +1 −1 ...ctions_manager/managed_projection/when_starting_a_managed_projection_without_slave_projections.cs
  146. +1 −1 ....Projections.Core.Tests/Services/projections_manager/query/a_running_foreach_stream_projection.cs
  147. +1 −1 ...tore/EventStore.Projections.Core.Tests/Services/projections_manager/query/a_running_projection.cs
  148. +10 −1 ...tions.Core.Tests/Services/projections_manager/specification_with_projection_management_service.cs
  149. +1 −5 ...EventStore/EventStore.Projections.Core.Tests/Services/{projections_manager → }/v8/v8_internals.cs
  150. +1 −1 ...Store.Projections.Core.Tests/Services/{projections_manager → }/v8/when_compiling_v8_projection.cs
  151. +2 −2 ...tStore.Projections.Core.Tests/Services/{projections_manager → }/v8/when_creating_v8_projection.cs
  152. +38 −3 ...tore.Projections.Core.Tests/Services/{projections_manager → }/v8/when_defining_a_v8_projection.cs
  153. +3 −2 ...EventStore.Projections.Core.Tests/Services/{projections_manager → }/v8/when_initializing_state.cs
  154. +2 −1 ...ons.Core.Tests/Services/{projections_manager → }/v8/when_not_returning_state_from_a_js_handler.cs
  155. +2 −1 ...e.Projections.Core.Tests/Services/{projections_manager → }/v8/when_partitioning_by_custom_rule.cs
  156. +2 −1 ...jections.Core.Tests/Services/{projections_manager → }/v8/when_running_a_faulting_v8_projection.cs
  157. +95 −0 ...e/EventStore.Projections.Core.Tests/Services/v8/when_running_a_projection_with_created_handler.cs
  158. +3 −2 ...Core.Tests/Services/{projections_manager → }/v8/when_running_a_v8_projection_emitting_metadata.cs
  159. +2 −2 ....Tests/Services/{projections_manager → }/v8/when_running_a_v8_projection_emitting_stream_links.cs
  160. +2 −1 ...s/Services/{projections_manager → }/v8/when_running_a_v8_projection_with_not_passing_filter_by.cs
  161. +2 −1 ...Core.Tests/Services/{projections_manager → }/v8/when_running_a_v8_projection_with_transform_by.cs
  162. +2 −2 ...rojections.Core.Tests/Services/{projections_manager → }/v8/when_running_bi_state_v8_projection.cs
  163. +2 −1 ...ons.Core.Tests/Services/{projections_manager → }/v8/when_running_body_reflecting_v8_projection.cs
  164. +2 −1 ...rojections.Core.Tests/Services/{projections_manager → }/v8/when_running_counting_v8_projection.cs
  165. +2 −2 ...rojections.Core.Tests/Services/{projections_manager → }/v8/when_running_emitting_v8_projection.cs
  166. +2 −1 ...jections.Core.Tests/Services/{projections_manager → }/v8/when_running_reflecting_v8_projection.cs
  167. +2 −1 ...e.Projections.Core.Tests/Services/{projections_manager → }/v8/when_v8_projection_loading_state.cs
  168. +7 −3 src/EventStore/EventStore.Projections.Core/EventStore.Projections.Core.csproj
  169. +80 −0 src/EventStore/EventStore.Projections.Core/Messages/AwakeReaderServiceMessage.cs
  170. +29 −0 src/EventStore/EventStore.Projections.Core/Messages/EventReaderSubscriptionMessage.cs
  171. +2 −0 src/EventStore/EventStore.Projections.Core/Messages/IQuerySources.cs
  172. +84 −17 src/EventStore/EventStore.Projections.Core/Messages/ParallelQueryProcessingMessages.cs
  173. +19 −0 src/EventStore/EventStore.Projections.Core/Messages/ProjectionManagementMessage.cs
  174. +6 −0 src/EventStore/EventStore.Projections.Core/Messages/QuerySourcesDefinition.cs
  175. +3 −0 src/EventStore/EventStore.Projections.Core/Messages/QuerySourcesDefinitionOptions.cs
  176. +61 −0 src/EventStore/EventStore.Projections.Core/Messages/ReaderSubscriptionMessage.cs
  177. +7 −6 src/EventStore/EventStore.Projections.Core/Prelude/1Prelude.js
  178. +84 −4 src/EventStore/EventStore.Projections.Core/Prelude/Projections.js
  179. +1 −0 src/EventStore/EventStore.Projections.Core/ProjectionManagerNode.cs
  180. +4 −0 src/EventStore/EventStore.Projections.Core/ProjectionWorkerNode.cs
  181. +13 −1 src/EventStore/EventStore.Projections.Core/Projections.cs
  182. +116 −0 src/EventStore/EventStore.Projections.Core/Services/AwakeReaderService/AwakeReaderService.cs
  183. +12 −0 src/EventStore/EventStore.Projections.Core/Services/Http/ProjectionsController.cs
  184. +17 −0 src/EventStore/EventStore.Projections.Core/Services/IProjectionStateHandler.cs
  185. +42 −4 src/EventStore/EventStore.Projections.Core/Services/Management/ManagedProjection.cs
  186. +14 −0 src/EventStore/EventStore.Projections.Core/Services/Management/ProjectionManager.cs
  187. +20 −10 src/EventStore/EventStore.Projections.Core/Services/Processing/AllStreamsCatalogEventReader.cs
  188. +5 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/ByHandleStatePartitionSelector.cs
  189. +10 −1 ...ntStore/EventStore.Projections.Core/Services/Processing/ByPositionStreamStatePartitionSelector.cs
  190. +17 −18 src/EventStore/EventStore.Projections.Core/Services/Processing/ByStreamCatalogEventReader.cs
  191. +11 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/ByStreamStatePartitionSelector.cs
  192. +6 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/BypassingEventFilter.cs
  193. +5 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/CatalogStreamPositionTagger.cs
  194. +6 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/CategoryEventFilter.cs
  195. +10 −9 src/EventStore/EventStore.Projections.Core/Services/Processing/CoreProjection.cs
  196. +1 −10 src/EventStore/EventStore.Projections.Core/Services/Processing/CoreProjectionCheckpointManager.cs
  197. +2 −2 src/EventStore/EventStore.Projections.Core/Services/Processing/CoreProjectionQueue.cs
  198. +1 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/EmittedEvent.cs
  199. +6 −2 src/EventStore/EventStore.Projections.Core/Services/Processing/EmittedLinkToWithRecategorization.cs
  200. +43 −21 src/EventStore/EventStore.Projections.Core/Services/Processing/EmittedStream.cs
  201. +9 −2 src/EventStore/EventStore.Projections.Core/Services/Processing/EventByTypeIndexEventFilter.cs
  202. +137 −65 src/EventStore/EventStore.Projections.Core/Services/Processing/EventByTypeIndexEventReader.cs
  203. +32 −7 src/EventStore/EventStore.Projections.Core/Services/Processing/EventByTypeIndexPositionTagger.cs
  204. +16 −3 src/EventStore/EventStore.Projections.Core/Services/Processing/EventFilter.cs
  205. +8 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/EventProcessedResult.cs
  206. +163 −5 ...Store/EventStore.Projections.Core/Services/Processing/EventProcessingProjectionProcessingPhase.cs
  207. +16 −4 src/EventStore/EventStore.Projections.Core/Services/Processing/EventReader.cs
  208. +13 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/EventReaderCoreService.cs
  209. +6 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/EventReorderingReaderSubscription.cs
  210. +51 −19 ...ventStore.Projections.Core/Services/Processing/EventSubscriptionBasedProjectionProcessingPhase.cs
  211. +17 −19 src/EventStore/EventStore.Projections.Core/Services/Processing/ExternallyFedByStreamEventReader.cs
  212. +106 −12 src/EventStore/EventStore.Projections.Core/Services/Processing/HeadingEventReader.cs
  213. +2 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/IEventProcessingPhase.cs
  214. +4 −25 ....Projections.Core/Services/Processing/{IndexedEventTypeEventFilter.cs → IProgressResultWriter.cs}
  215. +2 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/IProjectionProcessingPhase.cs
  216. +1 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/IReaderSubscription.cs
  217. +3 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/IResultWriter.cs
  218. +6 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/MultiStreamEventFilter.cs
  219. +52 −33 src/EventStore/EventStore.Projections.Core/Services/Processing/MultiStreamEventReader.cs
  220. +5 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/MultiStreamPositionTagger.cs
  221. +5 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/NoopStatePartitionSelector.cs
  222. +15 −15 src/EventStore/EventStore.Projections.Core/Services/Processing/ParallelProcessingLoadBalancer.cs
  223. +7 −3 ...e/EventStore.Projections.Core/Services/Processing/ParallelQueryMasterProjectionProcessingPhase.cs
  224. +2 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/ParallelQueryMasterReaderStrategy.cs
  225. +96 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/PartitionDeletedWorkItem.cs
  226. +6 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/PhasePositionTagger.cs
  227. +7 −2 src/EventStore/EventStore.Projections.Core/Services/Processing/PositionTagger.cs
  228. +1 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/PositionTracker.cs
  229. +13 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/PreTaggedPositionTagger.cs
  230. +11 −2 src/EventStore/EventStore.Projections.Core/Services/Processing/PreparePositionTagger.cs
  231. +0 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/ProcessingStrategySelector.cs
  232. +4 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/ProgressWorkItem.cs
  233. +6 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/ProjectionSourceDefinition.cs
  234. +28 −13 src/EventStore/EventStore.Projections.Core/Services/Processing/ReaderStrategy.cs
  235. +9 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/ReaderSubscription.cs
  236. +15 −6 ....Projections.Core/Services/Processing/{ProjectionSubscriptionBase.cs → ReaderSubscriptionBase.cs}
  237. +102 −7 src/EventStore/EventStore.Projections.Core/Services/Processing/ResolvedEvent.cs
  238. +18 −4 src/EventStore/EventStore.Projections.Core/Services/Processing/ResultWriter.cs
  239. +15 −3 src/EventStore/EventStore.Projections.Core/Services/Processing/SlaveResultWriter.cs
  240. +13 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/SourceDefinitionBuilder.cs
  241. +15 −3 src/EventStore/EventStore.Projections.Core/Services/Processing/SpoolStreamProcessingWorkItem.cs
  242. +1 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/StatePartitionSelector.cs
  243. +6 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/StreamEventFilter.cs
  244. +58 −25 src/EventStore/EventStore.Projections.Core/Services/Processing/StreamEventReader.cs
  245. +18 −1 src/EventStore/EventStore.Projections.Core/Services/Processing/StreamPositionTagger.cs
  246. +13 −3 src/EventStore/EventStore.Projections.Core/Services/Processing/TransactionFileEventFilter.cs
  247. +33 −34 src/EventStore/EventStore.Projections.Core/Services/Processing/TransactionFileEventReader.cs
  248. +12 −0 src/EventStore/EventStore.Projections.Core/Services/Processing/TransactionFilePositionTagger.cs
  249. +2 −1 .../EventStore.Projections.Core/Services/Processing/WriteQueryResultProjectionProcessingPhaseBase.cs
  250. +1 −1 src/EventStore/EventStore.Projections.Core/Services/ReaderSubscriptionDispatcher.cs
  251. +32 −0 src/EventStore/EventStore.Projections.Core/Services/v8/V8ProjectionStateHandler.cs
  252. +20 −2 src/EventStore/EventStore.Projections.Core/Standard/CategorizeEventsByStreamPath.cs
  253. +11 −0 src/EventStore/EventStore.Projections.Core/Standard/CategorizeStreamByPath.cs
  254. +27 −3 src/EventStore/EventStore.Projections.Core/Standard/IndexEventsByEventType.cs
  255. +11 −0 src/EventStore/EventStore.Projections.Core/Standard/IndexStreams.cs
  256. +100 −0 src/EventStore/EventStore.Projections.Core/Standard/StreamDeletedHelper.cs
  257. +10 −0 src/EventStore/EventStore.Projections.Core/Standard/StubHandler.cs
  258. +45 −0 src/EventStore/EventStore.Projections.Core/Utils/EncodingExtensions.cs
  259. +0 −3 src/EventStore/EventStore.Projections.Core/Utils/EnumExtensions.cs
  260. +24 −0 src/EventStore/EventStore.Projections.Core/v8/QueryScript.cs
  261. +7 −2 src/EventStore/EventStore.Projections.v8Integration/CompiledScript.cpp
  262. +1 −0 src/EventStore/EventStore.Projections.v8Integration/CompiledScript.h
  263. +4 −0 src/EventStore/EventStore.Projections.v8Integration/EventStore.Projections.v8Integration.vcxproj
  264. +1 −1 src/EventStore/EventStore.Projections.v8Integration/ModuleScript.cpp
  265. +4 −4 src/EventStore/EventStore.Projections.v8Integration/PreludeScript.cpp
  266. +4 −2 src/EventStore/EventStore.Projections.v8Integration/QueryScript.cpp
  267. +1 −1 src/EventStore/EventStore.SingleNode.Web/singlenode-web/js/es.debug.projection.js
  268. +14 −1 src/EventStore/EventStore.Transport.Http/Codecs/JsonCodec.cs
  269. +2 −1 src/EventStore/EventStore.Transport.Http/EntityManagement/HttpEntityManager.cs
  270. +1 −1 src/EventStore/EventStore.Transport.Http/EventStore.Transport.Http.csproj
  271. +17 −1 src/EventStore/EventStore.Transport.Http/Server/HttpAsyncServer.cs
  272. +10 −0 src/EventStore/EventStore.Web/Users/IndexUsersProjectionHandler.cs
  273. +5 −3 src/EventStore/Projections.Dev.WindowsOnly.sln
  274. BIN src/EventStore/libs/Newtonsoft.Json.dll
  275. BIN src/EventStore/libs/Newtonsoft.Json.pdb
  276. +1,022 −133 src/EventStore/libs/Newtonsoft.Json.xml
  277. +1 −0 src/ReformatOptions.DotSettings
@@ -127,7 +127,7 @@ public InspectionResult InspectPackage(TcpPackage package)
return new InspectionResult(InspectionDecision.Subscribed, "SubscriptionConfirmation");
}
- case TcpCommand.StreamEventAppeared:
+ case TcpCommand.StreamEventAppeared:
{
var dto = package.Data.Deserialize<ClientMessage.StreamEventAppeared>();
EventAppeared(new ResolvedEvent(dto.Event));
@@ -68,7 +68,7 @@ static class SystemMetadata
public const string SystemStreamAcl = "$systemStreamAcl";
}
- static class SystemEventTypes
+ public static class SystemEventTypes
{
public const string StreamDeleted = "$streamDeleted";
public const string StatsCollection = "$statsCollected";
@@ -67,7 +67,7 @@
<CodeAnalysisFailOnMissingRules>false</CodeAnalysisFailOnMissingRules>
</PropertyGroup>
<ItemGroup>
- <Reference Include="Newtonsoft.Json, Version=4.5.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
+ <Reference Include="Newtonsoft.Json, Version=6.0.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
<HintPath>..\libs\Newtonsoft.Json.dll</HintPath>
</Reference>
@@ -55,6 +55,11 @@ public Task Disable(IPEndPoint endPoint, string name, UserCredentials userCreden
return SendPost(endPoint.ToHttpUrl("/projection/{0}/command/disable", name), string.Empty, userCredentials, HttpStatusCode.OK);
}
+ public Task Abort(IPEndPoint endPoint, string name, UserCredentials userCredentials = null)
+ {
+ return SendPost(endPoint.ToHttpUrl("/projection/{0}/command/abort", name), string.Empty, userCredentials, HttpStatusCode.OK);
+ }
+
public Task CreateOneTime(IPEndPoint endPoint, string query, UserCredentials userCredentials = null)
{
return SendPost(endPoint.ToHttpUrl("/projections/onetime?type=JS"), query, userCredentials, HttpStatusCode.Created);
@@ -90,7 +90,7 @@ public void Disable(string name, UserCredentials userCredentials = null)
}
/// <summary>
- /// Asynchronously disables a projection.
+ /// Asynchronously aborts and disables a projection without writing a checkpoint.
/// </summary>
/// <param name="name">The name of the projection.</param>
/// <param name="userCredentials">Credentials for a user with permission to disable a projection.</param>
@@ -102,6 +102,29 @@ public Task DisableAsync(string name, UserCredentials userCredentials = null)
}
/// <summary>
+ /// Synchronously avborts and disables a projection without writing a checkpoint.
+ /// </summary>
+ /// <param name="name">The name of the projection.</param>
+ /// <param name="userCredentials">Credentials for a user with permission to disable a projection.</param>
+ public void Abort(string name, UserCredentials userCredentials = null)
+ {
+ Ensure.NotNullOrEmpty(name, "name");
+ AbortAsync(name, userCredentials).Wait();
+ }
+
+ /// <summary>
+ /// Asynchronously disables a projection.
+ /// </summary>
+ /// <param name="name">The name of the projection.</param>
+ /// <param name="userCredentials">Credentials for a user with permission to disable a projection.</param>
+ /// <returns>A task representing the operation.</returns>
+ public Task AbortAsync(string name, UserCredentials userCredentials = null)
+ {
+ Ensure.NotNullOrEmpty(name, "name");
+ return _client.Abort(_httpEndPoint, name, userCredentials);
+ }
+
+ /// <summary>
/// Synchronously creates a one-time query.
/// </summary>
/// <param name="query">The JavaScript source code for the query.</param>
@@ -26,6 +26,7 @@
// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
//
using System;
+using System.Text;
using EventStore.ClientAPI.Messages;
namespace EventStore.ClientAPI
@@ -65,6 +66,20 @@ public class RecordedEvent
/// </summary>
public readonly byte[] Metadata;
+
+#if DEBUG
+ public string DebugDataView
+ {
+ get { return Encoding.UTF8.GetString(Data); }
+ }
+
+ public string DebugMetadataView
+ {
+ get { return Encoding.UTF8.GetString(Metadata); }
+ }
+#endif
+
+
internal RecordedEvent(ClientMessage.EventRecord systemRecord)
{
EventStreamId = systemRecord.EventStreamId;
@@ -79,7 +79,7 @@ internal ResolvedEvent(ClientMessage.ResolvedEvent evnt)
internal ResolvedEvent(ClientMessage.ResolvedIndexedEvent evnt)
{
- Event = new RecordedEvent(evnt.Event);
+ Event = evnt.Event == null ? null : new RecordedEvent(evnt.Event);
Link = evnt.Link == null ? null : new RecordedEvent(evnt.Link);
OriginalPosition = null;
}
@@ -44,7 +44,7 @@
<WarningLevel>4</WarningLevel>
</PropertyGroup>
<ItemGroup>
- <Reference Include="Newtonsoft.Json, Version=4.5.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
+ <Reference Include="Newtonsoft.Json, Version=6.0.0.0, Culture=neutral, PublicKeyToken=30ad4fe6b2a6aeed, processorArchitecture=MSIL">
<SpecificVersion>False</SpecificVersion>
<HintPath>..\libs\Newtonsoft.Json.dll</HintPath>
</Reference>
@@ -33,7 +33,7 @@
namespace EventStore.Core.Tests.ClientAPI.Helpers
{
- internal class TestEvent
+ public class TestEvent
{
public static EventData NewTestEvent(string data = null, string metadata = null)
{
@@ -0,0 +1,62 @@
+// Copyright (c) 2012, Event Store LLP
+// All rights reserved.
+//
+// Redistribution and use in source and binary forms, with or without
+// modification, are permitted provided that the following conditions are
+// met:
+//
+// Redistributions of source code must retain the above copyright notice,
+// this list of conditions and the following disclaimer.
+// Redistributions in binary form must reproduce the above copyright
+// notice, this list of conditions and the following disclaimer in the
+// documentation and/or other materials provided with the distribution.
+// Neither the name of the Event Store LLP nor the names of its
+// contributors may be used to endorse or promote products derived from
+// this software without specific prior written permission
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+// HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+//
+
+using EventStore.ClientAPI;
+using EventStore.Core.Tests.ClientAPI.Helpers;
+using EventStore.Core.Tests.Helpers;
+using NUnit.Framework;
+
+namespace EventStore.Core.Tests.ClientAPI
+{
+ public abstract class SpecificationWithMiniNode : SpecificationWithDirectoryPerTestFixture
+ {
+ private MiniNode _node;
+ protected IEventStoreConnection _conn;
+
+ protected abstract void When();
+
+ [TestFixtureSetUp]
+ public override void TestFixtureSetUp()
+ {
+ base.TestFixtureSetUp();
+ _node = new MiniNode(PathName, skipInitializeStandardUsersCheck: false);
+ _node.Start();
+ _conn = TestConnection.Create(_node.TcpEndPoint);
+ _conn.Connect();
+ When();
+ }
+
+ [TestFixtureTearDown]
+ public override void TestFixtureTearDown()
+ {
+ _conn.Close();
+ _node.Shutdown();
+ base.TestFixtureTearDown();
+ }
+ }
+}
@@ -39,20 +39,12 @@
namespace EventStore.Core.Tests.ClientAPI
{
[TestFixture, Category("LongRunning")]
- public class read_all_events_backward_should: SpecificationWithDirectoryPerTestFixture
+ public class read_all_events_backward_should: SpecificationWithMiniNode
{
- private MiniNode _node;
- private IEventStoreConnection _conn;
private EventData[] _testEvents;
- [TestFixtureSetUp]
- public override void TestFixtureSetUp()
+ protected override void When()
{
- base.TestFixtureSetUp();
- _node = new MiniNode(PathName, skipInitializeStandardUsersCheck: false);
- _node.Start();
- _conn = TestConnection.Create(_node.TcpEndPoint);
- _conn.Connect();
_conn.SetStreamMetadata("$all", -1,
StreamMetadata.Build().SetReadRole(SystemRoles.All),
new UserCredentials(SystemUsers.Admin, SystemUsers.DefaultAdminPassword));
@@ -61,14 +53,6 @@ public override void TestFixtureSetUp()
_conn.AppendToStream("stream", ExpectedVersion.EmptyStream, _testEvents);
}
- [TestFixtureTearDown]
- public override void TestFixtureTearDown()
- {
- _conn.Close();
- _node.Shutdown();
- base.TestFixtureTearDown();
- }
-
[Test, Category("LongRunning")]
public void return_empty_slice_if_asked_to_read_from_start()
{
@@ -40,20 +40,12 @@
namespace EventStore.Core.Tests.ClientAPI
{
[TestFixture, Category("LongRunning")]
- public class read_all_events_forward_should: SpecificationWithDirectoryPerTestFixture
+ public class read_all_events_forward_should: SpecificationWithMiniNode
{
- private MiniNode _node;
- private IEventStoreConnection _conn;
private EventData[] _testEvents;
- [TestFixtureSetUp]
- public override void TestFixtureSetUp()
+ protected override void When()
{
- base.TestFixtureSetUp();
- _node = new MiniNode(PathName, skipInitializeStandardUsersCheck: false);
- _node.Start();
- _conn = TestConnection.Create(_node.TcpEndPoint);
- _conn.Connect();
_conn.SetStreamMetadata("$all", -1,
StreamMetadata.Build().SetReadRole(SystemRoles.All),
new UserCredentials(SystemUsers.Admin, SystemUsers.DefaultAdminPassword));
@@ -62,14 +54,6 @@ public override void TestFixtureSetUp()
_conn.AppendToStream("stream", ExpectedVersion.EmptyStream, _testEvents);
}
- [TestFixtureTearDown]
- public override void TestFixtureTearDown()
- {
- _conn.Close();
- _node.Shutdown();
- base.TestFixtureTearDown();
- }
-
[Test, Category("LongRunning")]
public void return_empty_slice_if_asked_to_read_from_end()
{
@@ -0,0 +1,82 @@
+// Copyright (c) 2012, Event Store LLP
+// All rights reserved.
+//
+// Redistribution and use in source and binary forms, with or without
+// modification, are permitted provided that the following conditions are
+// met:
+//
+// Redistributions of source code must retain the above copyright notice,
+// this list of conditions and the following disclaimer.
+// Redistributions in binary form must reproduce the above copyright
+// notice, this list of conditions and the following disclaimer in the
+// documentation and/or other materials provided with the distribution.
+// Neither the name of the Event Store LLP nor the names of its
+// contributors may be used to endorse or promote products derived from
+// this software without specific prior written permission
+// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+// HOLDER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+//
+
+using System.Linq;
+using EventStore.ClientAPI;
+using EventStore.ClientAPI.SystemData;
+using EventStore.Core.Data;
+using EventStore.Core.Services;
+using EventStore.Core.Tests.ClientAPI.Helpers;
+using EventStore.Core.Tests.Helpers;
+using NUnit.Framework;
+using ExpectedVersion = EventStore.ClientAPI.ExpectedVersion;
+using StreamMetadata = EventStore.ClientAPI.StreamMetadata;
+
+namespace EventStore.Core.Tests.ClientAPI
+{
+ [TestFixture, Category("LongRunning")]
+ public class read_all_events_forward_with_hard_deleted_stream_should : SpecificationWithMiniNode
+ {
+ private EventData[] _testEvents;
+
+ protected override void When()
+ {
+ _conn.SetStreamMetadata(
+ "$all", -1, StreamMetadata.Build().SetReadRole(SystemRoles.All),
+ new UserCredentials(SystemUsers.Admin, SystemUsers.DefaultAdminPassword));
+
+ _testEvents = Enumerable.Range(0, 20).Select(x => TestEvent.NewTestEvent(x.ToString())).ToArray();
+ _conn.AppendToStream("stream", ExpectedVersion.EmptyStream, _testEvents);
+ _conn.DeleteStream("stream", ExpectedVersion.Any, hardDelete: true);
+ }
+
+ [Test, Category("LongRunning")]
+ public void ensure_deleted_stream()
+ {
+ var res = _conn.ReadStreamEventsForward("stream", 0, 100, false);
+ Assert.AreEqual(SliceReadStatus.StreamDeleted, res.Status);
+ Assert.AreEqual(0, res.Events.Length);
+ }
+
+ [Test, Category("LongRunning")]
+ public void returns_all_events_including_tombstone()
+ {
+ AllEventsSlice read = _conn.ReadAllEventsForward(Position.Start, _testEvents.Length + 10, false);
+ Assert.That(
+ EventDataComparer.Equal(
+ _testEvents.ToArray(),
+ read.Events.Skip(read.Events.Length - _testEvents.Length - 1)
+ .Take(_testEvents.Length)
+ .Select(x => x.Event)
+ .ToArray()));
+ var lastEvent = read.Events.Last().Event;
+ Assert.AreEqual("stream", lastEvent.EventStreamId);
+ Assert.AreEqual(SystemEventTypes.StreamDeleted, lastEvent.EventType);
+ }
+ }
+}
Oops, something went wrong.

0 comments on commit 4d05ebe

Please sign in to comment.