### Question:
CoreTokenAdapter { public ResultHandler<Token, CoreTokenException> create(Token token) throws CoreTokenException { applyBlobStrategy(token); debug("Create: queued {0} Token {1}\n{2}", token.getType(), token.getTokenId(), token); final ResultHandler<Token, CoreTokenException> createHandler = handlerFactory.getCreateHandler(); dispatcher.create(token, createHandler); return createHandler; } @Inject  CoreTokenAdapter(TokenBlobStrategy strategy, TaskDispatcher dispatcher, ResultHandlerFactory handlerFactory,
                            CTSReaperInit reaperInit, @Named(CoreTokenConstants.CTS_DEBUG) Debug debug); ResultHandler<Token, CoreTokenException> create(Token token); Token read(String tokenId); ResultHandler<Token, CoreTokenException> updateOrCreate(Token token); ResultHandler<String, CoreTokenException> delete(String tokenId); Collection<Token> query(final TokenFilter tokenFilter); Collection<PartialToken> attributeQuery(final TokenFilter filter); void deleteOnQuery(final TokenFilter filter);  }### Answer:
@Test public void shouldCreateToken() throws LdapException, CoreTokenException { Token token = new Token("badger", TokenType.SESSION); adapter.create(token); verify(mockTaskDispatcher).create(eq(token), nullable(ResultHandler.class)); }
@Test public void shouldCreateToken() throws LdapException, CoreTokenException { Token token = new Token("badger", TokenType.SESSION); adapter.create(token); verify(mockTaskDispatcher).create(eq(token), any(ResultHandler.class)); }