Markus markus2610

markus2610 / ApiService.java

Last active August 29, 2015 14:17 — forked from dustin-graham/ApiService.java

	public static Observable<List<String>> paginatedThings(final Observable<Void> onNextObservable) {
	return Observable.create(new Observable.OnSubscribe<List<String>>() {
	@Override
	public void call(final Subscriber<? super List<String>> subscriber) {

	onNextObservable.subscribe(new Observer<Void>() {
	int latestPage = -1;
	@Override
	public void onCompleted() {
	subscriber.onCompleted();

markus2610 / NoBackpressureOps.java

Last active August 29, 2015 14:17 — forked from akarnokd/NoBackpressureOps.java

	package rxjava.issue;

	import java.util.Queue;
	import java.util.concurrent.*;
	import java.util.concurrent.atomic.AtomicInteger;

	import rx.*;
	import rx.Observable.Operator;
	import rx.Scheduler.Worker;
	import rx.functions.Action0;

markus2610 / gist:a0f32c074746d8a200e6

Last active August 29, 2015 14:17 — forked from elandau/gist:2a651e9d15d7d3c86178

	package io.reactivex.netty.examples.tcp.loadbalancer;

	import io.netty.buffer.ByteBuf;
	import io.netty.handler.codec.string.StringEncoder;
	import io.reactivex.netty.channel.Connection;
	import io.reactivex.netty.protocol.tcp.client.TcpClient;
	import io.reactivex.netty.protocol.tcp.server.TcpServer;
	import io.reactivex.netty.protocol.tcp.server.TcpServerImpl;
	import io.reactivex.netty.protocol.text.StringLineDecoder;

markus2610 / README.md

Last active August 29, 2015 14:17 — forked from hofmannsven/README.md

Using Git

markus2610 / WordPress.java

Last active August 29, 2015 14:17 — forked from anirudh24seven/WordPress.java

	package org.wordpress.android;

	import android.annotation.SuppressLint;
	import android.annotation.TargetApi;
	import android.app.Activity;
	import android.app.Application;
	import android.content.ComponentCallbacks2;
	import android.content.Context;
	import android.content.Intent;
	import android.content.SharedPreferences;

markus2610 / EachDirectoryPath.md

Last active August 29, 2015 14:16 — forked from granoeste/EachDirectoryPath.md

System directories

Method	Result
Environment.getDataDirectory()	/data
Environment.getDownloadCacheDirectory()	/cache
Environment.getRootDirectory()	/system

External storage directories

markus2610 / CountingFileRequestBody.java

Last active August 29, 2015 14:16 — forked from eduardb/CountingFileRequestBody.java

	public class CountingFileRequestBody extends RequestBody {

	private static final int SEGMENT_SIZE = 2048; // okio.Segment.SIZE

	private final File file;
	private final ProgressListener listener;
	private final String contentType;

	public CountingFileRequestBody(File file, String contentType, ProgressListener listener) {
	this.file = file;

markus2610 / gist:6c7c83420b93bcb8e9a9

Last active August 29, 2015 14:15 — forked from skehlet/gist:9418379

	package com.mirth.stevek.rxtest;

	import rx.Observable;
	import rx.functions.Action1;
	import rx.functions.Func1;
	import rx.functions.Func3;

	import java.util.HashMap;
	import java.util.Map;
	import java.util.concurrent.*;

markus2610 / EachDirectoryPath.md

Last active August 29, 2015 14:14 — forked from granoeste/EachDirectoryPath.md

System directories

Method	Result
Environment.getDataDirectory()	/data
Environment.getDownloadCacheDirectory()	/cache
Environment.getRootDirectory()	/system

External storage directories

markus2610 / gist:ff3b9e7eb781f1791ca3

Last active August 29, 2015 14:14 — forked from skehlet/gist:9418379

	package com.mirth.stevek.rxtest;

	import rx.Observable;
	import rx.functions.Action1;
	import rx.functions.Func1;
	import rx.functions.Func3;

	import java.util.HashMap;
	import java.util.Map;
	import java.util.concurrent.*;