Skip to content

Commit

Permalink
History doesn't support customMessageType
Browse files Browse the repository at this point in the history
only fetchMessages
  • Loading branch information
marcin-cebo committed Oct 28, 2024
1 parent d93ca77 commit cb101dd
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ public HistoryImpl(PubNub pubnub) {
@Override
@NotNull
protected Endpoint<PNHistoryResult> createRemoteAction() {
return pubnub.history(channel, start, end, count, reverse, includeTimetoken, includeMeta, false);
return pubnub.history(channel, start, end, count, reverse, includeTimetoken, includeMeta);
}

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -47,7 +47,6 @@ class EventEngineSteps(private val state: EventEngineState) {
pubnub: PubNub,
pnMessageResult: PNMessageResult,
) {
println("-=message: ${pnMessageResult.customMessageType}")
state.messagesList.add(pnMessageResult)
}

Expand Down Expand Up @@ -164,13 +163,11 @@ class EventEngineSteps(private val state: EventEngineState) {
state.messagesList.map { it::class.java },
CoreMatchers.hasItems(PNMessageResult::class.java),
)
println("-=size: ${state.messagesList.size}")
}
}

@Then("I receive 2 messages in my subscribe response")
fun i_receive_2_messages_in_my_subscribe_response(){
println("-=I receive 2 messages in my subscribe ")
await.pollInterval(50, TimeUnit.MILLISECONDS).atMost(2, TimeUnit.SECONDS).untilAsserted {
MatcherAssert.assertThat(
state.messagesList.size, Matchers.`is`(2)
Expand Down

0 comments on commit cb101dd

Please sign in to comment.