Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add live and current variant to AllEvents query and their documentation #4523

Merged

Conversation

Arkatufus
Copy link
Contributor

@Arkatufus Arkatufus commented Jul 17, 2020

Continuation of #4521
Closes #4518

Updates:

  • The previous PR lacks the live and current variants.
  • Add AllEvents and CurrentAllEvents documentation
  • Updates AllPersistenceIds and PersistenceIds documentation

@Aaronontheweb
Copy link
Member

@Arkatufus still waiting on docs for this, right?

@Arkatufus
Copy link
Contributor Author

yes, documentation should be in now

@Arkatufus Arkatufus changed the title Add live and current variant to AllEvents query Add live and current variant to AllEvents query and their documentation Jul 17, 2020
@Aaronontheweb
Copy link
Member

@Arkatufus looks like we have a compilation error here

Copy link
Member

@Aaronontheweb Aaronontheweb left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM - great work @Arkatufus

_tickCancelable = Context.System.Scheduler.ScheduleTellRepeatedlyCancelable(refreshInterval, refreshInterval, Self, EventsByTagPublisher.Continue.Instance, Self);
}

protected override long ToOffset => long.MaxValue;
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM - need this to make IIsTimeForReplay function correctly on live queries

@@ -37,42 +33,35 @@ public void ReadJournal_should_implement_IAllEventsQuery()
}

[Fact]
public virtual void ReadJournal_query_AllEvents_should_find_existing_events()
public virtual void ReadJournal_query_AllEvents_should_find_new_events()
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM


probe.ExpectComplete();
probe.ExpectNoMsg(TimeSpan.FromMilliseconds(500));
// everything before "streaming" are not included, since exclusive offset
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@Aaronontheweb Aaronontheweb merged commit 8fd4af4 into akkadotnet:dev Jul 28, 2020
@Arkatufus Arkatufus deleted the Add_live_and_current_AllEvents_query branch March 8, 2021 13:31
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
2 participants