,O      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNonei.NET TimeSpan: TimeSpan represents a duration of time. A TimeSpan can be negative or positive. Sorry!   (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(+0` NRepresents stream metadata as a series of properties for system data and a  object for user metadata.  When the stream is soft-deleted.3When the stream is either not found or 'no stream'.The name of the stream.#The version of the metadata format.A $ containing user-specified metadata.Represents stream metadata with strongly typed properties for system values and a dictionary-like interface for custom values.3The maximum number of events allowed in the stream.0The maximum age of events allowed in the stream.tThe event number from which previous events can be scavenged. This is used to implement soft-deletion of streams.9The amount of time for which the stream head is cachable.'The access control list for the stream.TAn enumerable of key-value pairs of keys to JSON text for user-provider metadata./Represents an access control list for a stream. -Roles and users permitted to read the stream.!1Roles and users permitted to write to the stream."2Roles and users permitted to delete to the stream.#2Roles and users permitted to read stream metadata.$3Roles and users permitted to write stream metadata.%Global  Connection settings, In seconds-!Represents reconnection strategy..%Holds login and password information./;Represents a multi-request transaction with the EventStore.LThe ID of the transaction. This can be used to recover a transaction later.The name of the stream.Expected version of the stream.0(Asynchronously commits this transaction.19Asynchronously writes to a transaction in the EventStore.2Rollback this transaction.3PRepresents the direction of read operation (both from $all an usual streams).4From end to beginning5From beginning to end6BA structure representing a single event or an resolved link event.8.The event, or the resolved link event if this 6 is a link event.9The link event if this 6 is a link event.:&Represents a previously written event.<-The event stream that this event belongs to.=*Unique identifier representing this event.>#Number of this event in the stream.?Type of this event.@$Representing the data of this event.A5Representing the metadada associated with this event.B;Indicates whether the content is internally marked as json.C7Representing when this event was created in the system.D"Returned after deleting a stream. K of the write.G#Returned after writing to a stream.I$Next expected version of the stream.JK of the write.KcA structure referring to a potential logical record position in the EventStore transaction file.MCommit position of the recordNPrepare position of the recordO,Constants used for expected version control.}The use of expected version can be a bit tricky especially when discussing idempotency assurances given by the EventStore.QThe EventStore will assure idempotency for all operations using any value in O except for ] . When using ]` the EventStore will do its best to assure idempotency but will not guarantee idempotency.PHolds event data.QRContains event information like its type and data. Only used for write queries.SReasonUExpected, FoundVStreamXStreamYStream and Expected Version[!Creates a event using JSON format\.Create a event with metadata using JSON format]GThis write should not conflict with anything and should always succeed.^jThe stream being written to should not yet exist. If it does exist treat that as a concurrency problem._zThe stream should exist and should be empty. If it does not exist or is not empty, treat that as a concurrency problem.`oStates that the last event written to the stream should have a sequence number matching your expected value.a/Representing the start of the transaction file.b-Representing the end of the transaction file.cDReturns the event that was read or which triggered the subscription.If this 6a represents a link event, the link will be the original event, otherwise it will be the event.dIndicates whether this 6 is a resolved link event.e&The stream name of the original event.guIndicates how many times we should try to reconnect to the server. A value less than or equal to 0 means no retry.hTIndicates we should try to reconnect to the server until the end of the Universe.iDefault global settings.Millisecond timespanj" with no role or users whatsoever.k with everything set to , using j and an empty .l4Sets role names with read permission for the stream.m<Sets a single role name with read permission for the stream.n5Sets role names with write permission for the stream.o=Sets a single role name with write permission for the stream.p6Sets role names with delete permission for the stream.q>Sets a single role name with delete permission for the stream.r=Sets role names with metadata read permission for the stream.sESets a single role name with metadata read permission for the stream.t>Sets role names with metadata write permission for the stream.uFSets a single role name with metadata write permission for the stream.v Builds a  from a .w Modifies a  using a .x8Sets the maximum number of events allowed in the stream.y5Sets the maximum age of events allowed in the stream.zBSets the event number from which previous events can be scavenged.{>Sets the amount of time for which the stream head is cachable.~ Sets a custom metadata property. Builds a  from a . Modifies a  using a   !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMN      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMONOPQPRQSTUVWRSTUVWXYXYZZ Event typeEvent ID, generated if  Event data[\[\]^_]^_`` Event typeEvent IDData content typeMetadata content type Event dataMetadataabcabdefgcdehfLoginPasswordghijkijklmnopqrstuvwxyz{lmnopqrstuvwxyz{|}~|}~  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMN      !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMONOPQPRQSTUVWRSTUVWXYXYZZ[\[\]^_]^_``abcabdefgcdehfghijkijklmnopqrstuvwxyz{lmnopqrstuvwxyz{|}~y   !"#$%&'()*+,-./0123546789: ;<=>?@ABCDEFGHIJKLMN       !"#$%&'()*+,-./0123456789:;<=>?@ABCDEMLKJIHGFOQPONPRQSTUVWRYXWVUTSXZYZ[\[\]^_]^_``abcabdefgcdehfghijkijklmnopqrstuvwxyz{lmnopqrstuvwxyz{|}~|}~(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0U QRepresents a subscription to a single stream or $all stream in the EventStore.ID of the subscription.?The name of the stream to which the subscription is subscribed.WDetermines whether or not any link events encontered in the stream will be resolved.]The last commit position seen on the subscription (if this a subscription to $all stream).aThe last event number seen on the subscription (if this is a subscription to a single stream)./Asynchronously unsubscribe from the the stream.1Represents the reason subscription drop happened.Awaits for the next 6.N$(C) 2015 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone+M HostName Port MaxAttempt's value (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone:M$ (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0             (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(04The result of a read operation from the $all stream.,Representing the status of the read attempt.FRepresenting the position where the next slice should be read from.CRepresenting the position where the next slice should be read from.?Representing whether or not this is the end of the $all stream.The events read.The direction of read request.QEnumeration detailing the possible outcomes of reading a slice of $all stream.% !"#$%&'()$  !"#$%&'() (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0:Result of a single event read operation to the EventStore.Attempt status Stream name Event numberEEnumeration representing the status of a single event read operation. *+,-./01234567Resolve link TOS89:;<7 *+,-./0123456789:;< (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0 CRepresents the result of a single read operation to the EventStore.,Representing the status of the read attempt.The name of the stream read.OThe starting point (represented as a sequence number) of the read operation.'The next event number that can be read.$The last event number in the stream.:Representing whether or not this is the end of the stream.The events read represented as 6"The direction of the read request.JEnumeration detailing the possible outcomes of reading a slice of a stream)=>?@ABCDEFGHIJKLMNOPQRSTO =>?@ABCDEFGHIJKLMNOPQRST (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(0UVWXYZ[\]^_`abcStreamExpected versionEventsRequire masterdefghijd UVWXYZ[\]^_`abcdefghij(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNoneklmnopqkklmnopq(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNonerrr(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNoneM)stuvwxyz{|}~XYZstuvwxyz{|}~(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone(C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone+$Representing catch-up subscriptions.?The name of the stream to which the subscription is subscribed.,Asynchronously unsubscribes from the stream.8Errors that could arise during a catch-up subscription. % value represents the stream name.Awaits for the next 6. Waits until " subscription catch-up its stream.Non blocking version of .  (C) 2014 Yorick Laupa(see the file LICENSE)!Yorick Laupa <yo.eight@gmail.com> provisional non-portableNone4Represents a connection to a single EventStore node.Creates a new ] to a single node. It maintains a full duplex connection to the EventStore. An EventStore  operates quite differently than say a SQL connection. Normally when you use a SQL connection you want to keep the connection open for a much longer of time than when you use a SQL connection.0Another difference is that with the EventStore  all operation are handled in a full async manner (even if you call the synchronous behaviors). Many threads can use an EvenStore  at the same time or a single thread can make many asynchronous requests. To get the most performance out of the connection it is generally recommend to use it in this way.Asynchronously closes the .Sends a single Q to given stream.Sends a list of Q to given stream.Deletes given stream.%Starts a transaction on given stream.'Reads a single event from given stream.)Reads events from a given stream forward.*Reads events from a given stream backward.*Reads events from the $all stream forward.*Reads events from the $all stream backwardSubcribes to given stream.Subcribes to $all stream.HSubscribes to given stream. If last checkpoint is defined, this will  from that event number, otherwise from the beginning. Once last stream event reached up, a subscription request will be sent using .Same as  but applied to $all stream..Asynchronously sets the metadata for a stream.HostNamePort Stream name Stream name Stream name Hard delete Stream name Stream name Event numberResolve Link Tos Stream nameFrom event number Batch sizeResolve Link Tos Stream nameFrom event number Batch sizeResolve Link Tos Batch sizeResolve Link Tos Batch sizeResolve Link Tos Stream nameResolve Link TosResolve Link Tos Stream nameResolve Link TosLast checkpoint Batch sizeResolve Link TosLast checkpoint Batch size  !"#$%&'()*+,-./0123456789:;<=>?@ABCDEFGHIJKLMNOPQRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~QPZ[\.%&'()*+,-ghfi   !"#$jkvwlmnopqrstuxyz{|}~ /012021DEFGHIJ:;<=>?@ABCKLMN3546789RYXWVUTSdceabO]^_` !"#!$%&'()**+,-./011234567789:;<=>?@ABCDEFGGHIJJKLMNOPQRSSTUUVWXXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~                         ?     @ !!"#$%&'())*+,,-./0012344567889:;<<=>?@ABCDEFGHIJKLMNOP]QRSTUVWXYZ[\]^_`abcdefghijklmnopqrstuvwxyz{|}~>                                                                              ! " # $    % & ' ' ( ) * + , - . . / 0 1 2 3 4    5 6 789:;<=>?@@AABCDDEEFFGGHHIJKLMNOPQQRSTUVWXYZ[\]^_`aabcdefghijklmno5pqrstuvwxyz{|}~peventstore-0.7.2.1Database.EventStore(Database.EventStore.Internal.Util.Sodium%Database.EventStore.Internal.TimeSpan"Database.EventStore.Internal.Types1Database.EventStore.Internal.Manager.Subscription'Database.EventStore.Internal.Connection%Database.EventStore.Internal.Packages.Database.EventStore.Internal.Manager.OperationTimeSpan timeSpanTickstimeSpanHoursMinsSecstimeSpanDaysHoursMinsSecstimeSpanDaysHoursMinsSecsMillistimeSpanGetTickstimeSpanGetDaystimeSpanGetHourstimeSpanGetMinutestimeSpanGetSecondstimeSpanGetMillisStreamMetadataResultDeletedStreamMetadataResultNotFoundStreamMetadataResultstreamMetaResultStreamstreamMetaResultVersionstreamMetaResultDataStreamMetadataBuilderStreamACLBuilderBuilderStreamMetadatastreamMetadataMaxCountstreamMetadataMaxAgestreamMetadataTruncateBeforestreamMetadataCacheControlstreamMetadataACLstreamMetadataCustom StreamACLstreamACLReadRolesstreamACLWriteRolesstreamACLDeleteRolesstreamACLMetaReadRolesstreamACLMetaWriteRolesSettingss_heartbeatIntervals_heartbeatTimeouts_requireMaster s_credentialss_retrys_reconnect_delay_secsRetry Credentials TransactiontransactionCommittransactionSendEventstransactionRollback ReadDirectionBackwardForward ResolvedEventresolvedEventRecordresolvedEventLink RecordedEventrecordedEventStreamIdrecordedEventIdrecordedEventNumberrecordedEventTyperecordedEventDatarecordedEventMetadatarecordedEventIsJsonrecordedEventCreated DeleteResultdeleteStreamPosition WriteResultwriteNextExpectedVersion writePositionPositionpositionCommitpositionPrepareExpectedVersion EventDataEventOperationException ServerErrorProtobufDecodingErrorInvalidServerResponse AccessDeniedInvalidTransaction StreamDeletedWrongExpectedVersion createEventwithJsonwithJsonAndMetadata anyStreamnoStream emptyStream exactStream positionStart positionEndresolvedEventOriginal eventResolvedresolvedEventOriginalStreamId credentialsatMost keepRetryingdefaultSettingsemptyStreamACLemptyStreamMetadata setReadRoles setReadRole setWriteRoles setWriteRolesetDeleteRoles setDeleteRolesetMetaReadRolessetMetaReadRolesetMetaWriteRolessetMetaWriteRolebuildStreamACLmodifyStreamACL setMaxCount setMaxAgesetTruncateBeforesetCacheControlsetACL modifyACLsetCustomPropertybuildStreamMetadatamodifyStreamMetadata SubscriptionsubId subStreamsubResolveLinkTossubLastCommitPossubLastEventNumbersubUnsubscribe DropReasonD_PersistentSubscriptionDeleted D_NotFoundD_AccessDeniedD_UnsubscribedsubAwaitConnectionException MaxAttemptAllEventsSliceallEventsSliceResultallEventsSliceFromallEventsSliceNextallEventsSliceIsEOSallEventsSliceEventsallEventsSliceDirection ReadAllResultRA_ACCESS_DENIEDRA_ERRORRA_NOT_MODIFIED RA_SUCCESS ReadResultreadResultStatusreadResultStreamIdreadResultEventNumberreadResultResolvedEventReadEventResultRE_ACCESS_DENIEDRE_ERRORRE_STREAM_DELETED RE_NO_STREAM RE_NOT_FOUND RE_SUCCESSStreamEventsSlicestreamEventsSliceResultstreamEventsSliceStreamIdstreamEventsSliceStartstreamEventsSliceNextstreamEventsSliceLaststreamEventsSliceIsEOSstreamEventsSliceEventsstreamEventsSliceDirectionReadStreamResultRS_ACCESS_DENIEDRS_ERRORRS_NOT_MODIFIEDRS_STREAM_DELETED RS_NO_STREAM RS_SUCCESSCatchup catchupStreamcatchupUnsubscribe CatchupErrorCatchupSubscriptionDropReasonCatchupUnexpectedStreamStatusCatchupStreamDeleted catchupAwaitwaitTillCatchup hasCaughtUp Connectionconnectshutdown sendEvent sendEvents deleteStreamtransactionStart readEventreadStreamEventsForwardreadStreamEventsBackwardreadAllEventsForwardreadAllEventsBackward subscribesubscribeToAll subscribeFromsubscribeToAllFromsetStreamMetadatagetStreamMetadata pushAsync pushAsync2 pushAsync3 pushAsync4 FormatLiteralNegativePositiveparseFormatLiteral parseDays parseHours parseMinutes parseSeconds parseMillisparseBaseTimeSpan parseTimeSpanticksPerMillisecondticksPerSecondticksPerMinute ticksPerHour ticksPerDaypaddedtimeSpanBuilder$fFromJSONTimeSpan$fToJSONTimeSpan$fShowTimeSpan transactionIdtransactionStreamIdtransactionExpectedVersion msDiffTime Data.MaybeNothing aeson-0.8.1.0Data.Aeson.Types.InternalObject KeepRetryingAtMostPackage packageCmdpackageCorrelation packageData packageCred credLogin credPasswordFlag AuthenticatedNoneResolvedEventBufresolvedEventBufEventresolvedEventBufLinkresolvedEventBufCommitPositionresolvedEventBufPreparePositionResolvedIndexedEventresolvedIndexedRecordresolvedIndexedLink EventRecordeventRecordStreamIdeventRecordNumber eventRecordIdeventRecordTypeeventRecordDataTypeeventRecordMetadataTypeeventRecordDataeventRecordMetadataeventRecordCreatedeventRecordCreatedEpochTransactionCommitCompletedtransactionCCIdtransactionCCResulttransactionCCMessagetransactionCCFirstNumbertransactionCCLastNumbertransactionCCPreparePositiontransactionCCCommitPositionTransactionCommittransactionCommitIdtransactionCommitRequireMasterTransactionWriteCompletedtransactionWCIdtransactionWCResulttransactionWCMessageTransactionWritetransactionWriteIdtransactionWriteEventstransactionWriteRequireMasterTransactionStartCompletedtransactionSCIdtransactionSCResulttransactionSCMessageTransactionStarttransactionStartStreamIdtransactionStartExpectedVersiontransactionStartRequireMasterNewEvent newEventId newEventTypenewEventDataTypenewEventMetadataType newEventDatanewEventMetadataOpResultOP_ACCESS_DENIEDOP_INVALID_TRANSACTIONOP_STREAM_DELETEDOP_WRONG_EXPECTED_VERSIONOP_FORWARD_TIMEOUTOP_COMMIT_TIMEOUTOP_PREPARE_TIMEOUT OP_SUCCESSExact EmptyStreamNoStreamAnyJson eventTypeeventId eventDataOperationExceptionalInternalExceptionStoppedConnectionClosedByServer eventDataTypeeventMetadataTypeeventDataByteseventMetadataBytesexpVersionInt32newEventnewTransactionStartnewTransactionWritenewTransactionCommittoUTCnewRecordedEventnewResolvedEventnewResolvedEventFromBuf flagWord8customMetaToPairs streamACLJSONstreamMetadataJSON p_readRoles p_writeRoles p_deleteRolesp_metaReadRolesp_metaWriteRolesp_maxAge p_maxCountp_truncateBeforep_cacheControlp_aclinternalMetaPropertieskeepUserPropertiesparseNominalDiffTimeparseStreamACLparseStreamMetadatabuild$fFromJSONStreamMetadata$fDecodeResolvedEventBuf$fDecodeResolvedIndexedEvent$fDecodeEventRecord"$fDecodeTransactionCommitCompleted$fEncodeTransactionCommit!$fDecodeTransactionWriteCompleted$fEncodeTransactionWrite!$fDecodeTransactionStartCompleted$fEncodeTransactionStart$fEncodeNewEvent$fExceptionOperationException$fExceptionInternalExceptionDropped droppedReason droppedSub droppedIdNewSubscriptionCB Confirmation Subscribe_subId _subCallback _subStream_subResolveLinkTosAppeared_appSub_appEvtManager _pendings_subscriptionssubChanPendingpenConfpenCbUnsubscribeFromStreamSubscriptionDropped dropReasonStreamEventAppearedstreamResolvedEventSubscriptionConfirmationsubscribeLastCommitPossubscribeLastEventNumberSubscribeToStreamsubscribeStreamIdsubscribeResolveLinkTossubscribeToStream initManagersubscriptionConfirmedstreamEventAppearedsubscriptionDroppedmaybeDecodeMessageonConfirmationonEventAppeared confirmSubsubscriptionNetworkcreateSubscribePackagecreateUnsubscribePackage dropError confirmedremove$fEncodeUnsubscribeFromStream$fDecodeSubscriptionDropped$fDecodeStreamEventAppeared $fDecodeSubscriptionConfirmation$fEncodeSubscribeToStreamconnUUID connClose connFlushconnSendconnRecv newConnectionsecsregularConnection$fExceptionConnectionExceptionheartbeatPackageheartbeatResponsePackage putPackagecredSize mandatorySizeResponseRemoveRegisterOperationParams opSettings opRequestCmd opResponseCmd opRequest opSuccess opFailure OperationoperationCreatePackageoperationInspectDecision Subscribed Reconnection EndOperation DoNothingcreateOperation createPackage inspectiondeeperInspectionoperationNetworkunexpectedDecisionregisterresponseDeleteStreamCompleted_deleteCompletedResult_deleteCompletedMessage_deleteCompletedPreparePosition_deleteCompletedCommitPosition DeleteStream_deleteStreamId_deleteStreamExpectedVersion_deleteStreamRequireMaster_deleteStreamHardDeletenewDeleteStreamdeleteStreamOperationinspectsucceedfailed$fDecodeDeleteStreamCompleted$fEncodeDeleteStreamReadAllEventsCompletedreadAECCommitPositionreadAECPreparePosition readAECEventsreadAECNextCommitPositionreadAECNextPreparePosition readAECResult readAECError ReadAllEventsreadAllEventsCommitPositionreadAllEventsPreparePositionreadAllEventsMaxCountreadAllEventsResolveLinkTosreadAllEventsRequireMasternewReadAllEventsnewAllEventsSlicereadAllEventsOperation$fDecodeReadAllEventsCompleted$fEncodeReadAllEventsReadEventCompletedreadCompletedResultreadCompletedIndexedEventreadCompletedError ReadEventreadEventStreamIdreadEventNumberreadEventResolveLinkTosreadEventRequireMaster newReadEvent newReadResultreadEventOperation$fDecodeReadEventCompleted$fEncodeReadEventReadStreamEventsCompleted_readSECEvents_readSECResult_readSECNextNumber_readSECLastNumber_readSECEndOfStream_readSECLastCommitPosition _readSECErrorReadStreamEvents _readStreamId_readStreamEventNumber_readStreamMaxCount_readStreamResolveLinkTos_readStreamRequireMasternewReadStreamEventsnewStreamEventsSlicereadStreamEventsOperation!$fDecodeReadStreamEventsCompleted$fEncodeReadStreamEventsWriteEventsCompleted_writeCompletedResult_writeCompletedMessage_writeCompletedFirstNumber_writeCompletedLastNumber_writeCompletedPreparePosition_writeCompletedCommitPosition WriteEvents_writeStreamId_writeExpectedVersion _writeEvents_writeRequireMasternewWriteEventswriteEventsOperationeventToNewEvent$fDecodeWriteEventsCompleted$fEncodeWriteEvents readerThreadgetLengthPrefix getPackagegetFlaggetCredEntryLengthgetCredentialsgetUUID writerThreadCleanupSnapshotConnectionSnapshot_conHost_conPort Reconnected ReconnectCleanup ConnectedConnectStateOnline_uuidCon _packageCount_host_port_cleanupOffline ProcessorprocessorConnectprocessorShutdownprocessorNewOperationprocessorNewSubcription newProcessorheartbeatRequestCmdnetworkconnectSnapshot connection recoveringreconnectSnapshotcleanupSnapshot connected reconnectedreceivedTransactionEnv_transSettings_transProcessor_transStreamId_transExpectedVersiontransactionStartOperation inspectTrans succeedTranscreateTransactiontransactionWriteOperationtransactionCommitOperation inspectWrite succeedWrite inspectCommit succeedCommit createAsync text-1.2.0.6Data.Text.InternalText catchupChancatchupSubMVardefaultBatchSize catchupStartcatchupAllStartreadEventsTill readAllTillkeepAwaitingSubEvent$fExceptionCatchupError conProcessor conSettingsreadStreamEventsCommonreadAllEventsCommonextractStreamMetadataResult metaStreamOf async-2.0.2Control.Concurrent.AsyncmapConcurrently concurrentlyrace_racelink2linkwaitBothwaitEitherCancel waitEither_ waitEitherwaitEitherCatchCancelwaitEitherCatch waitAnyCancelwaitAnywaitAnyCatchCancel waitAnyCatch cancelWithcancelpollSTM waitCatchSTMwaitSTMpoll waitCatchwaitwithAsyncOnWithUnmaskwithAsyncWithUnmask withAsyncOnwithAsyncBound withAsyncasyncOnWithUnmaskasyncWithUnmaskasyncOn asyncBoundasync asyncThreadIdAsyncrunConcurrently Concurrently