I hereby claim:
- I am jgrgt on github.
- I am jensgeiregat (https://keybase.io/jensgeiregat) on keybase.
- I have a public key whose fingerprint is 0E60 1C75 4EAE 8991 7293 839C F40A 1ED9 AC49 6619
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
| class DefaultXConnector { | |
| // ... | |
| @Override | |
| rx.Observable<JsonObject> getSessionWithTimeout(JsonObject jsonObject, long timeout) { | |
| log.debug('Getting session with timeout {} for query: {} ({}, {})', timeout, jsonObject, this, this.eventBus) | |
| return eventBus.sendWithTimeout(ServiceLocation.BUS_SESSION_SERVICE_LOCATION, jsonObject, timeout).map(body(true)) | |
| } | |
| public static <T> Func1<RxMessage<T>, T> body(boolean logMessage) { | |
| return { RxMessage<T> message -> |
| { | |
| "devDependencies": { | |
| "connect": "~3.3.4", | |
| "proxy-middleware": "~0.11.0", | |
| "url": "~0.10.3", | |
| "http": "0.0.0" | |
| }, | |
| "scripts": { | |
| "start": "node server.js" | |
| } |
| @Grab('com.netflix.rxjava:rxjava-joins:0.19.6') | |
| import rx.Observable | |
| import rx.functions.Func1 | |
| import rx.functions.Action1 | |
| import java.util.concurrent.TimeUnit | |
| def range = new IntRange(5, 0) | |
| range.each { println it} |
| /** | |
| * Publishing this publicly because it took me so long to get to this stage: | |
| * - Using a memory-mapped byte buffer because I will handle *large* files. | |
| * - Not too happy with the end of my loop, but I could not find how to check for the end of the buffer otherwise. | |
| */ | |
| import org.bson.BsonBinaryReader | |
| import org.bson.BsonReader | |
| import org.bson.Document | |
| import org.bson.codecs.DecoderContext | |
| import org.bson.codecs.DocumentCodec |
| substitutions: | |
| device_name: 'Digoo Station' | |
| external_location: 'Balcony' | |
| rf_receiver_pin: '4' | |
| digoo_sensor_channel: '2' | |
| digoo_sensor_id: '9' | |
| esphome: | |
| name: digoo-station | |
| comment: 'ESP station for environment monitoring' |