Skip to content

Instantly share code, notes, and snippets.

Sorry, something went wrong. Reload?
Sorry, we cannot display this file.
Sorry, this file is invalid so it cannot be displayed.
package etl;
import java.util.Arrays;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
/**
* Created by david.wursteisen on 02/07/2015.
@dwursteisen
dwursteisen / MongoExample.java
Created April 2, 2015 12:56
This code snippet show how MongoDB Async driver can be used with RxJava
import java.util.concurrent.CountDownLatch;
import com.mongodb.CursorType;
import com.mongodb.async.client.MongoClients;
import com.mongodb.async.client.MongoCollection;
import com.mongodb.async.client.MongoDatabase;
import org.bson.Document;
import rx.Observable;
[info] application - CALL 15 GoDown
[info] application - CALL 9 GoDown
[info] application - CALL 4 GoDown
[info] application - CALL 1 GoUp
[info] application - CALL 10 GoDown
[info] application - CALL 1 GoUp
[info] application - CALL 13 GoUp
[info] application - CALL 10 GoDown
[info] application - NEXT COMMAND Open
[info] application - NEXT COMMAND Close
package controllers;
import play.mvc.Controller;
import java.util.ArrayList;
import java.util.List;
public class Application extends Controller {
package itw;
import java.util.Collection;
public class AboutCollections {
/**
* La méthode retourne une liste avec les élements de stringList sans les doublons.
*
package org.bitbucket.dwursteisen.stripes;
import com.google.appengine.tools.development.testing.LocalDatastoreServiceTestConfig;
import com.google.appengine.tools.development.testing.LocalServiceTestHelper;
import org.bitbucket.dwursteisen.model.Pics;
import org.bitbucket.dwursteisen.model.Spot;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;