SubscriptionProcessor (java 5.5.18-SNAPSHOT API)

All Superinterfaces:

java.lang.AutoCloseable, java.io.Closeable, deltix.util.lang.Disposable
```
public interface SubscriptionProcessor
extends deltix.util.lang.Disposable
```
Executes message processing in current thread. Note: thread will be blocked till processing is explicitly stopped by other thread. Only one "process*" method can be used during processors lifecycle.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`processMessagesUntilStopped()`	Executes message processing (blocks on this method) till processing is stopped from another thread (via call to close()).
`void`	`processMessagesWhileTrue(java.util.function.BooleanSupplier condition)`	Executes message processing (blocks on this method) while `condition` is `true` and till processing is stopped from another thread (via call to close()).

Methods inherited from interface deltix.util.lang.Disposable
close

- Method Detail
  - processMessagesUntilStopped
```
void processMessagesUntilStopped()
```
    Executes message processing (blocks on this method) till processing is stopped from another thread (via call to close()). Closes processor upon completion.
  - processMessagesWhileTrue
```
void processMessagesWhileTrue(java.util.function.BooleanSupplier condition)
```
    Executes message processing (blocks on this method) while condition is true and till processing is stopped from another thread (via call to close()). Closes processor upon completion.
    
    Parameters:
    
    condition - processing will be stopped if this condition returns false. Note: it's not guarantied that condition is checked after each message.