Skip to content

Instantly share code, notes, and snippets.

#include <SPI.h>
#include <Ethernet.h>
#include <PubSubClient.h>
#include <dht.h>
// Update these with values suitable for your network.
byte mac[] = { 0xDE, 0xED, 0xBA, 0xFE, 0xFE, 0xED };
IPAddress ip(192, 168, 1, 5);
IPAddress server(192, 168, 1, 2);
// Find All, Subscribe, Be Active until disposed or completed.
Disposable subscription = taxiRepository.findWithTailableCursorBy()
.doOnNext(System.out::println)
.doOnComplete(() -> System.out.println("Finished"))
.doOnTerminate(() -> System.out.println("Terminated"))
.subscribe();
Thread.sleep(1000);
taxiRepository.save(new Taxi(UUID.randomUUID().toString(), "ABC-1234", 4)).subscribe();
// Find by Number, Aggregate to a List, Block until finish
List myTaxis = rxJava2TaxiRepository
.findByNumber("CAL-4259")
.toList()
.blockingGet();
// Find by Number, Aggregate to a List, Block until finish
List myTaxis = taxiRepository
.findByNumber("CAL-4259")
.collectList()
.block();
public interface RxJava2TaxiRepository
extends RxJava2CrudRepository {
Flowable findByNumber(String taxiNumber);
@Tailable
Flowable findWithTailableCursorBy();
}
public interface ReactiveTaxiRepository
extends ReactiveCrudRepository {
Flux findByNumber(String taxiNumber);
@Tailable
Flux findWithTailableCursorBy();
}
@SpringBootApplication(exclude = {MongoAutoConfiguration.class,
MongoDataAutoConfiguration.class })
@EnableReactiveMongoRepositories
@AutoConfigureAfter(EmbeddedMongoAutoConfiguration.class)
public class ApplicationConfiguration
extends AbstractReactiveMongoConfiguration {
private final Environment environment;
public ApplicationConfiguration(Environment environment) {
@shazin
shazin / pom.xml
Last active December 9, 2017 05:18
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
<version>2.0.0.M6</version>
</dependency>
<dependency>
<groupId>io.reactivex.rxjava2</groupId>
<artifactId>rxjava</artifactId>
<version>2.1.1</version>
{
"chain": [
{
"index": 1,
"timestamp": 1507040257518,
"transactions": [],
"proof": 100,
"previousHash": "1"
},
{
@RestController
@RequestMapping("/people")
public class PeopleController {
@Autowired
private PersonService blockingService;
@GetMapping
public Flux<Person> getPeople() {
return Flux.fromIterable(blockingService.getPeople());