Shazin Sadakath shazin

shazin / ThingsBoardClient.ino

Created February 18, 2018 07:58

	#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);

shazin / TailableCursor

Last active December 9, 2017 05:27

	// 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();

shazin / RxJava2RepoUsage

Created December 9, 2017 05:11

	// Find by Number, Aggregate to a List, Block until finish
	List myTaxis = rxJava2TaxiRepository
	.findByNumber("CAL-4259")
	.toList()
	.blockingGet();

shazin / ReactiveRepoUsage

Created December 9, 2017 05:10

	// Find by Number, Aggregate to a List, Block until finish
	List myTaxis = taxiRepository
	.findByNumber("CAL-4259")
	.collectList()
	.block();

shazin / RxJava2TaxiRepository.java

Created December 9, 2017 05:09

	public interface RxJava2TaxiRepository
	extends RxJava2CrudRepository {

	Flowable findByNumber(String taxiNumber);

	@Tailable
	Flowable findWithTailableCursorBy();

	}

shazin / ReactiveTaxiRepository.java

Last active December 9, 2017 05:14

	public interface ReactiveTaxiRepository
	extends ReactiveCrudRepository {

	Flux findByNumber(String taxiNumber);

	@Tailable
	Flux findWithTailableCursorBy();

	}

shazin / ApplicationConfiguration.java

Last active December 9, 2017 05:13

	@SpringBootApplication(exclude = {MongoAutoConfiguration.class,
	MongoDataAutoConfiguration.class })
	@EnableReactiveMongoRepositories
	@AutoConfigureAfter(EmbeddedMongoAutoConfiguration.class)
	public class ApplicationConfiguration
	extends AbstractReactiveMongoConfiguration {

	private final Environment environment;

	public ApplicationConfiguration(Environment environment) {

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>

shazin / gist:e39b178c9fc11295557dfc61e416f705

Created October 3, 2017 15:38

BlockChain

shazin / PeopleController.java

Created September 10, 2017 05:15

	@RestController
	@RequestMapping("/people")
	public class PeopleController {

	@Autowired
	private PersonService blockingService;

	@GetMapping
	public Flux<Person> getPeople() {
	return Flux.fromIterable(blockingService.getPeople());