Я лишь начал изучать RxJava и нуждаюсь в помощи в нескольких вопросах, чтобы выполнить задание.
1.
У меня есть сервис, который красит фигурки и должен возвращать фигурку после задержки — то есть через секунду (для кружков) или две(для квадратиков) после того, как его об этом попросили. Блокировать поток нельзя, нужно использовать таймеры.
Пока я смог добиться задержки таким способом, но она занимает заметно больше, чем секунду. Я добавил Scheduler
, поскольку без него результат не возвращается вообще:
public Observable<PaintedCircle> paint(Shape shape) {
return Observable
.timer(1, TimeUnit.SECONDS, Schedulers.immediate())
.flatMap(x -> Observable.just(new PaintedCircle(shape.getSize())));
}
Этот сервис покраски я вызываю из кода ниже (код пока черновой). Там же фигурки раскладываются по коробкам по 5 штук и выводятся в консоль:
public class Consumer {
private static final int CIRCLE_MIN_SIZE = 30;
public static void main(String[] args) {
Producer producer = new Producer();
while (!producer.doesShouldStop()) {
Observable.from(producer.produceShapes(40))
.filter(shape -> shape instanceof Square || shape instanceof Circle && shape.getSize() > CIRCLE_MIN_SIZE)
.flatMap(shape -> shape.getPaintingService().paint(shape))
.buffer(5)
.map(shapes -> new Box(shapes))
.forEach(System.out::println);
}
}
}
Как улучшить реализацию задержки?
2.
Второй вопрос касается создания самих самих фигурок. Квадратики и кружки должны создаваться случайным образом и случайным размером. Пока что я использую для этого обычную Джаву, но, вероятно, это тоже можно делать с помощью реактивности. Пока мой код выглядит так:
public class Producer {
private int MAX_SHAPE_SIZE = 100;
private int counter;
private boolean shouldStop;
List<Shape> produceShapes(int amount) {
List<Shape> shapes = new ArrayList<>();
Random random = new Random();
System.out.println("Produced following shapes:");
for (int i = 0; i < amount; i++) {
int coin = random.nextInt(2);
int size = Math.abs(random.nextInt(MAX_SHAPE_SIZE));
Shape shape = coin == 0 ? new Circle(size) : new Square(size);
shapes.add(shape);
System.out.print(shape);
}
System.out.println();
if (++counter == 3) {
shouldStop = true;
}
return shapes;
}
boolean doesShouldStop() {
return shouldStop;
}
}
Можно ли это переписать с помощью RxJava?
Кроме того, по условию задачи, Producer
после трех циклов должен сообщить Consumer
'у, что фигурок больше нет. Как видно на коде Consumer
'а, пока это делается с помощью цикла while
, но это нужно тоже изменить — вероятно, с помощью отписки.
Прошу помочь.