Bugfixes

src/main/java/it/tdlight/reactiveapi/ReactiveApiPublisher.java

@@ -135,7 +135,7 @@ public abstract class ReactiveApiPublisher {
 		var publishedResultingEvents = telegramClient
 				.subscribeOn(Schedulers.parallel())
 				// Handle signals, then return a ResultingEvent
-				.flatMapIterable(this::onSignal)
+				.concatMapIterable(this::onSignal)
 				.doFinally(s -> LOG.trace("Finalized telegram client events"))
 
 				// Transform resulting events using all the registered resulting event transformers

src/main/java/it/tdlight/reactiveapi/transformer/DefaultOptions.java

@@ -34,7 +34,7 @@ public class DefaultOptions implements ResultingEventTransformer {
 
 	@Override
 	public Flux<ResultingEvent> transform(boolean isBot, Flux<ResultingEvent> events) {
-		return events.flatMapIterable(event -> {
+		return events.concatMapIterable(event -> {
 
 			// Append the options if the initial auth state is intercepted
 			if (event instanceof ClientBoundResultingEvent clientBoundResultingEvent

src/main/java/it/tdlight/reactiveapi/transformer/DisableChatDatabase.java

@@ -11,7 +11,7 @@ public class DisableChatDatabase implements ResultingEventTransformer {
 
 	@Override
 	public Flux<ResultingEvent> transform(boolean isBot, Flux<ResultingEvent> events) {
-		return events.flatMapIterable(event -> {
+		return events.concatMapIterable(event -> {
 
 			// Change option
 			if (event instanceof TDLibBoundResultingEvent tdLibBoundResultingEvent

src/main/java/it/tdlight/reactiveapi/transformer/DisableFileDatabase.java

@@ -11,7 +11,7 @@ public class DisableFileDatabase implements ResultingEventTransformer {
 
 	@Override
 	public Flux<ResultingEvent> transform(boolean isBot, Flux<ResultingEvent> events) {
-		return events.flatMapIterable(event -> {
+		return events.concatMapIterable(event -> {
 
 			// Change option
 			if (event instanceof TDLibBoundResultingEvent tdLibBoundResultingEvent

src/main/java/it/tdlight/reactiveapi/transformer/DisableMessageDatabase.java

@@ -11,7 +11,7 @@ public class DisableMessageDatabase implements ResultingEventTransformer {
 
 	@Override
 	public Flux<ResultingEvent> transform(boolean isBot, Flux<ResultingEvent> events) {
-		return events.flatMapIterable(event -> {
+		return events.concatMapIterable(event -> {
 
 			// Change option
 			if (event instanceof TDLibBoundResultingEvent tdLibBoundResultingEvent

src/main/java/it/tdlight/reactiveapi/transformer/TdlightDefaultOptions.java

@@ -29,7 +29,7 @@ public class TdlightDefaultOptions implements ResultingEventTransformer {
 
 	@Override
 	public Flux<ResultingEvent> transform(boolean isBot, Flux<ResultingEvent> events) {
-		return events.flatMapIterable(event -> {
+		return events.concatMapIterable(event -> {
 
 			// Append the options if the initial auth state is intercepted
 			if (event instanceof ClientBoundResultingEvent clientBoundResultingEvent