ddebrunner

import java.io.IOException;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Objects;
import java.util.Random;
import java.util.function.Supplier;

ddebrunner

from streamsx.topology.topology import Topology
import streamsx.topology.context

from sseclient import SSEClient

class SSEReader(object):
    """
    Read Server-sent events.
    Includes checkpointing/consistent region support
    so that recovery from a checkpoint starts at the last

ddebrunner

from functools import lru_cache

# Example taken from: https://docs.python.org/3/library/functools.html#functools.lru_cache
# 
# With this example the cache will be Python VM wide, thus if
# multiple map(fibs.fib) were invoked in the topology they
# wouldbe sharing the same cache.

@lru_cache()
def fib(n):

ddebrunner