RXJavaChain.xtend

	def Link getChain(Single<?> single) {
		try {
			val source = single.getClass().getDeclaredField("source")
			source.setAccessible(true)
			val sourceInstance = source.get(single)
			if(sourceInstance instanceof Single) {
				return new Link(Optional.ofNullable(getChain(sourceInstance)), single.toString())
			} else {
				return new Link(Optional.empty(), single.toString())
			}
		} catch(NoSuchFieldException e) {
			return new Link(Optional.empty(), single.toString())
		}
	}
	
	@Data static class Link {
		val Optional<Link> source		
		val String name
	}